Class SingleThreadedIteratorSource<T>
java.lang.Object
org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource<T>
- Type Parameters:
T
- The return type of the source
- All Implemented Interfaces:
Serializable
,org.apache.flink.api.connector.source.Source<T,
,org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>, Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>> org.apache.flink.api.connector.source.SourceReaderFactory<T,
,org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>
- Direct Known Subclasses:
MonitorSource
@Internal
public abstract class SingleThreadedIteratorSource<T>
extends Object
implements org.apache.flink.api.connector.source.Source<T,org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>
Implementation of the Source V2 API which uses an iterator to read the elements, and uses a
single thread to do so.
- See Also:
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.flink.api.connector.source.SplitEnumerator<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,
Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>> createEnumerator
(org.apache.flink.api.connector.source.SplitEnumeratorContext<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> enumContext) org.apache.flink.api.connector.source.SourceReader<T,
org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> createReader
(org.apache.flink.api.connector.source.SourceReaderContext readerContext) org.apache.flink.core.io.SimpleVersionedSerializer<Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>>
org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>
org.apache.flink.api.connector.source.SplitEnumerator<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,
Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>> restoreEnumerator
(org.apache.flink.api.connector.source.SplitEnumeratorContext<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> enumContext, Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> checkpoint) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.flink.api.java.typeutils.ResultTypeQueryable
getProducedType
Methods inherited from interface org.apache.flink.api.connector.source.Source
getBoundedness
-
Constructor Details
-
SingleThreadedIteratorSource
public SingleThreadedIteratorSource()
-
-
Method Details
-
createEnumerator
public org.apache.flink.api.connector.source.SplitEnumerator<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>> createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> enumContext) - Specified by:
createEnumerator
in interfaceorg.apache.flink.api.connector.source.Source<T,
org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>, Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>>
-
restoreEnumerator
public org.apache.flink.api.connector.source.SplitEnumerator<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>,Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>> restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> enumContext, Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> checkpoint) - Specified by:
restoreEnumerator
in interfaceorg.apache.flink.api.connector.source.Source<T,
org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>, Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>>
-
getSplitSerializer
public org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>> getSplitSerializer()- Specified by:
getSplitSerializer
in interfaceorg.apache.flink.api.connector.source.Source<T,
org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>, Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>>
-
getEnumeratorCheckpointSerializer
public org.apache.flink.core.io.SimpleVersionedSerializer<Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>> getEnumeratorCheckpointSerializer()- Specified by:
getEnumeratorCheckpointSerializer
in interfaceorg.apache.flink.api.connector.source.Source<T,
org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>, Collection<org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource.GlobalSplit<T>>>
-
createReader
-