Class SocketSource.DummySplit

  • All Implemented Interfaces:
    SourceSplit
    Enclosing class:
    SocketSource

    public static class SocketSource.DummySplit
    extends Object
    implements SourceSplit
    Placeholder because the socket itself implicitly represents the only split and does not require an actual split object.
    • Constructor Detail

      • DummySplit

        public DummySplit()
    • Method Detail

      • splitId

        public String splitId()
        Description copied from interface: SourceSplit
        Get the split id of this source split.
        Specified by:
        splitId in interface SourceSplit
        Returns:
        id of this source split.