Interface SerializableRecordEmitter<T>
-
- All Superinterfaces:
org.apache.flink.connector.base.source.reader.RecordEmitter<RecordAndPosition<T>,T,IcebergSourceSplit>
,java.io.Serializable
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@Internal @FunctionalInterface public interface SerializableRecordEmitter<T> extends org.apache.flink.connector.base.source.reader.RecordEmitter<RecordAndPosition<T>,T,IcebergSourceSplit>, java.io.Serializable
-
-
Method Summary
Static Methods Modifier and Type Method Description static <T> SerializableRecordEmitter<T>
defaultEmitter()
static <T> SerializableRecordEmitter<T>
emitterWithWatermark(SplitWatermarkExtractor extractor)
-
-
-
Method Detail
-
defaultEmitter
static <T> SerializableRecordEmitter<T> defaultEmitter()
-
emitterWithWatermark
static <T> SerializableRecordEmitter<T> emitterWithWatermark(SplitWatermarkExtractor extractor)
-
-