org.apache.flink.table.connector.format

Interface Format

All Known Subinterfaces:

DecodingFormat<I>, EncodingFormat<I>

All Known Implementing Classes:

ChangelogCsvFormat

@PublicEvolving
public interface Format

Base interface for connector formats.

Depending on the kind of external system, a connector might support different encodings for reading and writing rows. This interface is an intermediate representation before constructing actual runtime implementation.

Formats can be distinguished along two dimensions:

• Context in which the format is applied (DynamicTableSource or DynamicTableSink).
• Runtime implementation interface that is required (e.g. DeserializationSchema or some bulk interface).

A DynamicTableFactory can search for a format that it is accepted by the connector.

See Also:

DecodingFormat, EncodingFormat

Method Summary

Modifier and Type	Method and Description
ChangelogMode	getChangelogMode() Returns the set of changes that a connector (and transitively the planner) can expect during runtime.

Method Detail

getChangelogMode

ChangelogMode getChangelogMode()

Returns the set of changes that a connector (and transitively the planner) can expect during runtime.