public static interface DynamicTableSink.Context
DynamicTableSink.SinkRuntimeProvider
.
It offers utilities by the planner for creating runtime implementation with minimal dependencies to internal data structures.
Methods should be called in DynamicTableSink.getSinkRuntimeProvider(Context)
. The returned
instances are Serializable
and can be directly passed into the runtime implementation
class.
Modifier and Type | Method and Description |
---|---|
DynamicTableSink.DataStructureConverter |
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. |
<T> TypeInformation<T> |
createTypeInformation(DataType consumedDataType)
Creates type information describing the internal data structures of the given
DataType . |
boolean |
isBounded()
Returns whether a runtime implementation can expect a finite number of rows.
|
boolean isBounded()
This information might be derived from the session's execution mode and/or kind of query.
<T> TypeInformation<T> createTypeInformation(DataType consumedDataType)
DataType
.TableSchema.toPhysicalRowDataType()
DynamicTableSink.DataStructureConverter createDataStructureConverter(DataType consumedDataType)
DataType
that can be passed into a runtime implementation.
For example, RowData
and its fields can be converted into a Row
, or
the internal representation for structured types can be converted back into the original
(possibly nested) POJO.
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.