org.apache.paimon.table.sink

Interface TableWriteImpl.RecordExtractor<T>

Enclosing class:

TableWriteImpl<T>

public static interface TableWriteImpl.RecordExtractor<T>

Extractor to extract T from the SinkRecord.

Method Summary

Modifier and Type	Method and Description
T	extract(SinkRecord record, RowKind rowKind)

Method Detail

extract

T extract(SinkRecord record,
          RowKind rowKind)