Modifier and Type | Method and Description |
---|---|
DynamicTableSource.DataStructureConverter |
DynamicTableSource.Context.createDataStructureConverter(DataType producedDataType)
Creates a converter for mapping between objects specified by the given
DataType
and Flink's internal data structures that can be passed into a runtime implementation. |
Constructor and Description |
---|
ChangelogCsvDeserializer(List<LogicalType> parsingTypes,
DynamicTableSource.DataStructureConverter converter,
TypeInformation<RowData> producedTypeInfo,
String columnDelimiter) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSource.DataStructureConverter |
LookupRuntimeProviderContext.createDataStructureConverter(DataType producedDataType) |
DynamicTableSource.DataStructureConverter |
ScanRuntimeProviderContext.createDataStructureConverter(DataType producedDataType) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.