Class FromElementsSplit

  • All Implemented Interfaces:
    org.apache.flink.api.connector.source.SourceSplit

    public class FromElementsSplit
    extends Object
    implements org.apache.flink.api.connector.source.SourceSplit
    The split of the FromElementsSource.
    • Constructor Detail

      • FromElementsSplit

        public FromElementsSplit​(int emitNum)
    • Method Detail

      • getEmitNum

        public int getEmitNum()
      • setEmitNum

        public void setEmitNum​(int emitNum)
      • splitId

        public String splitId()
        Specified by:
        splitId in interface org.apache.flink.api.connector.source.SourceSplit