org.apache.flink.table.connector

Interface RuntimeConverter

All Superinterfaces:

Serializable

All Known Subinterfaces:

DynamicTableSink.DataStructureConverter, DynamicTableSource.DataStructureConverter

@PublicEvolving
public interface RuntimeConverter
extends Serializable

Base interface for converting data during runtime.

Instances of this interface are provided by the planner. They are used for converting between data structures or performing other mapping transformations.

Because runtime converters are Serializable, instances can be directly passed into a runtime implementation, stored in a member variable, and used when it comes to the execution.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	RuntimeConverter.Context Context for conversions during runtime.

Method Summary

Modifier and Type	Method and Description
void	open(RuntimeConverter.Context context) Initializes the converter during runtime.

Method Detail

open

void open(RuntimeConverter.Context context)

Initializes the converter during runtime.

This should be called in the open() method of a runtime class.