Class ContinuousIcebergEnumerator

  • All Implemented Interfaces:
    java.lang.AutoCloseable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,​IcebergEnumeratorState>

    @Internal
    public class ContinuousIcebergEnumerator
    extends java.lang.Object
    • Method Detail

      • close

        public void close()
                   throws java.io.IOException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,​IcebergEnumeratorState>
        Throws:
        java.io.IOException
      • shouldWaitForMoreSplits

        protected boolean shouldWaitForMoreSplits()
        return true if enumerator should wait for splits like in the continuous enumerator case
      • handleSplitRequest

        public void handleSplitRequest​(int subtaskId,
                                       @Nullable
                                       java.lang.String requesterHostname)
        Specified by:
        handleSplitRequest in interface org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,​IcebergEnumeratorState>
      • handleSourceEvent

        public void handleSourceEvent​(int subtaskId,
                                      org.apache.flink.api.connector.source.SourceEvent sourceEvent)
        Specified by:
        handleSourceEvent in interface org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,​IcebergEnumeratorState>