org.apache.flink.connector.file.src.util

Interface RecordMapperWrapperRecordIterator.RecordMapper<I,O>

Enclosing class:

RecordMapperWrapperRecordIterator<I,O>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface RecordMapperWrapperRecordIterator.RecordMapper<I,O>

Record mapper definition.

Method Summary

Modifier and Type	Method and Description
O	map(I in) Map the record.

Method Detail

map

O map(I in)

Map the record. Both input value and output value are expected to be non-null.