Package | Description |
---|---|
org.apache.flink.table.connector.sink | |
org.apache.flink.table.runtime.connector.sink |
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) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.