Package org.apache.iceberg.flink.source.reader

Interface SerializableRecordEmitter<T>

All Superinterfaces:

org.apache.flink.connector.base.source.reader.RecordEmitter<RecordAndPosition<T>,T,IcebergSourceSplit>, 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>, Serializable

Method Summary

Static Methods

Modifier and Type	Method	Description
static <T> SerializableRecordEmitter<T>	defaultEmitter()
static <T> SerializableRecordEmitter<T>	emitterWithWatermark(SplitWatermarkExtractor extractor)

Methods inherited from interface org.apache.flink.connector.base.source.reader.RecordEmitter

emitRecord

Method Details

defaultEmitter

static <T> SerializableRecordEmitter<T> defaultEmitter()

emitterWithWatermark

static <T> SerializableRecordEmitter<T> emitterWithWatermark(SplitWatermarkExtractor extractor)