org.apache.flink.table.runtime.connector.sink

Class SinkRuntimeProviderContext

java.lang.Object

org.apache.flink.table.runtime.connector.sink.SinkRuntimeProviderContext

All Implemented Interfaces:

DynamicTableSink.Context

@Internal
public final class SinkRuntimeProviderContext
extends Object
implements DynamicTableSink.Context

Implementation of DynamicTableSink.Context.

Constructor Summary

Constructors

Constructor and Description
SinkRuntimeProviderContext(boolean isBounded)

Method Summary

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.
TypeInformation<?>	createTypeInformation(DataType consumedDataType) Creates type information describing the internal data structures of the given DataType.
TypeInformation<?>	createTypeInformation(LogicalType consumedLogicalType) Creates type information describing the internal data structures of the given LogicalType.
boolean	isBounded() Returns whether a runtime implementation can expect a finite number of rows.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SinkRuntimeProviderContext

public SinkRuntimeProviderContext(boolean isBounded)

Method Detail

isBounded

public boolean isBounded()

Description copied from interface: DynamicTableSink.Context

Returns whether a runtime implementation can expect a finite number of rows.

This information might be derived from the session's execution mode and/or kind of query.

Specified by:

isBounded in interface DynamicTableSink.Context

createTypeInformation

public TypeInformation<?> createTypeInformation(DataType consumedDataType)

Description copied from interface: DynamicTableSink.Context

Creates type information describing the internal data structures of the given DataType.

Specified by:

createTypeInformation in interface DynamicTableSink.Context

See Also:

ResolvedSchema.toPhysicalRowDataType()

createTypeInformation

public TypeInformation<?> createTypeInformation(LogicalType consumedLogicalType)

Description copied from interface: DynamicTableSink.Context

Creates type information describing the internal data structures of the given LogicalType.

Specified by:

createTypeInformation in interface DynamicTableSink.Context

createDataStructureConverter

public DynamicTableSink.DataStructureConverter createDataStructureConverter(DataType consumedDataType)

Description copied from interface: DynamicTableSink.Context

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.

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.

Specified by:

createDataStructureConverter in interface DynamicTableSink.Context

See Also:

LogicalType.supportsOutputConversion(Class)