Uses of Interface
org.apache.flink.table.connector.sink.DynamicTableSink.DataStructureConverter

Packages that use DynamicTableSink.DataStructureConverter

Package	Description
org.apache.flink.connector.file.table.batch
org.apache.flink.table.connector.sink
org.apache.flink.table.runtime.connector.sink
org.apache.flink.table.runtime.operators.sink

Uses of DynamicTableSink.DataStructureConverter in org.apache.flink.connector.file.table.batch

Methods in org.apache.flink.connector.file.table.batch with parameters of type DynamicTableSink.DataStructureConverter

Modifier and Type	Method	Description
static DataStreamSink<Row>	BatchSink.createBatchNoCompactSink(DataStream<RowData> dataStream, DynamicTableSink.DataStructureConverter converter, FileSystemOutputFormat<Row> fileSystemOutputFormat, int parallelism, boolean parallelismConfigured)

Uses of DynamicTableSink.DataStructureConverter in org.apache.flink.table.connector.sink

Methods in org.apache.flink.table.connector.sink that return DynamicTableSink.DataStructureConverter

Modifier and Type	Method	Description
DynamicTableSink.DataStructureConverter	DynamicTableSink.Context.createDataStructureConverter(DataType consumedDataType)	Creates a converter for mapping between Flink's internal data structures and objects specified by the given DataType that can be passed into a runtime implementation.

Uses of DynamicTableSink.DataStructureConverter in org.apache.flink.table.runtime.connector.sink

Methods in org.apache.flink.table.runtime.connector.sink that return DynamicTableSink.DataStructureConverter

Modifier and Type	Method	Description
DynamicTableSink.DataStructureConverter	SinkRuntimeProviderContext.createDataStructureConverter(DataType consumedDataType)

Uses of DynamicTableSink.DataStructureConverter in org.apache.flink.table.runtime.operators.sink

Constructors in org.apache.flink.table.runtime.operators.sink with parameters of type DynamicTableSink.DataStructureConverter

Constructor	Description
OutputConversionOperator(RowData.FieldGetter atomicFieldGetter, DynamicTableSink.DataStructureConverter converter, int rowtimeIndex, boolean consumeRowtimeMetadata)