Interface MetadataConverter
-
- All Superinterfaces:
Serializable
- All Known Subinterfaces:
RowDataMetadataConverter
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface @Internal public interface MetadataConverter extends Serializable
A converter convertsSourceRecordmetadata into Flink internal data structures.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Objectread(org.apache.kafka.connect.source.SourceRecord record)
-
-
-
Method Detail
-
read
Object read(org.apache.kafka.connect.source.SourceRecord record)
-
-