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