Modifier and Type | Method and 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. |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink.DataStructureConverter |
SinkRuntimeProviderContext.createDataStructureConverter(DataType consumedDataType) |
Constructor and Description |
---|
OutputConversionOperator(RowData.FieldGetter atomicFieldGetter,
DynamicTableSink.DataStructureConverter converter,
int rowtimeIndex,
boolean consumeRowtimeMetadata) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.