Interface | Description |
---|---|
TaskWriterFactory<T> |
Factory to create
TaskWriter |
Class | Description |
---|---|
AvroGenericRecordToRowDataMapper |
This util class converts Avro GenericRecord to Flink RowData.
|
FlinkAppenderFactory | |
FlinkSink | |
FlinkSink.Builder | |
RowDataTaskWriterFactory |