Uses of Interface
org.apache.flink.table.connector.source.DynamicTableSource.Context

Packages that use DynamicTableSource.Context

Package	Description
org.apache.flink.formats.json.canal
org.apache.flink.formats.json.debezium
org.apache.flink.formats.json.maxwell
org.apache.flink.formats.json.ogg
org.apache.flink.streaming.connectors.kafka.table
org.apache.flink.table.connector.format
org.apache.flink.table.connector.source
org.apache.flink.table.examples.java.connectors
org.apache.flink.table.runtime.connector.source

Uses of DynamicTableSource.Context in org.apache.flink.formats.json.canal

Methods in org.apache.flink.formats.json.canal with parameters of type DynamicTableSource.Context

Modifier and Type	Method and Description
DeserializationSchema<RowData>	CanalJsonDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType, int[][] projections)

Uses of DynamicTableSource.Context in org.apache.flink.formats.json.debezium

Methods in org.apache.flink.formats.json.debezium with parameters of type DynamicTableSource.Context

Modifier and Type	Method and Description
DeserializationSchema<RowData>	DebeziumJsonDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType, int[][] projections)

Uses of DynamicTableSource.Context in org.apache.flink.formats.json.maxwell

Methods in org.apache.flink.formats.json.maxwell with parameters of type DynamicTableSource.Context

Modifier and Type	Method and Description
DeserializationSchema<RowData>	MaxwellJsonDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType, int[][] projections)

Uses of DynamicTableSource.Context in org.apache.flink.formats.json.ogg

Methods in org.apache.flink.formats.json.ogg with parameters of type DynamicTableSource.Context

Modifier and Type	Method and Description
DeserializationSchema<RowData>	OggJsonDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType)

Uses of DynamicTableSource.Context in org.apache.flink.streaming.connectors.kafka.table

Methods in org.apache.flink.streaming.connectors.kafka.table with parameters of type DynamicTableSource.Context

Modifier and Type	Method and Description
DeserializationSchema<RowData>	UpsertKafkaDynamicTableFactory.DecodingFormatWrapper.createRuntimeDecoder(DynamicTableSource.Context context, DataType producedDataType)

Uses of DynamicTableSource.Context in org.apache.flink.table.connector.format

Methods in org.apache.flink.table.connector.format with parameters of type DynamicTableSource.Context

Modifier and Type	Method and Description
I	DecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType) Creates runtime decoder implementation that is configured to produce data of the given data type.
default I	ProjectableDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType projectedPhysicalDataType)
I	ProjectableDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType, int[][] projections) Creates runtime decoder implementation that is configured to produce data of type Projection.of(projections).project(physicalDataType).

Uses of DynamicTableSource.Context in org.apache.flink.table.connector.source

Subinterfaces of DynamicTableSource.Context in org.apache.flink.table.connector.source

Modifier and Type	Interface and Description
static interface	LookupTableSource.LookupContext Context for creating runtime implementation via a LookupTableSource.LookupRuntimeProvider.
static interface	ScanTableSource.ScanContext Context for creating runtime implementation via a ScanTableSource.ScanRuntimeProvider.

Uses of DynamicTableSource.Context in org.apache.flink.table.examples.java.connectors

Methods in org.apache.flink.table.examples.java.connectors with parameters of type DynamicTableSource.Context

Modifier and Type	Method and Description
DeserializationSchema<RowData>	ChangelogCsvFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType producedDataType)

Uses of DynamicTableSource.Context in org.apache.flink.table.runtime.connector.source

Classes in org.apache.flink.table.runtime.connector.source that implement DynamicTableSource.Context

Modifier and Type	Class and Description
class	LookupRuntimeProviderContext Implementation of LookupTableSource.Context.
class	ScanRuntimeProviderContext Implementation of ScanTableSource.Context.