Interface Format
-
- All Known Subinterfaces:
BulkDecodingFormat<T>
,DecodingFormat<I>
,EncodingFormat<I>
,ProjectableDecodingFormat<I>
- All Known Implementing Classes:
CanalJsonDecodingFormat
,ChangelogCsvFormat
,CsvFileFormatFactory.CsvBulkDecodingFormat
,DebeziumJsonDecodingFormat
,MaxwellJsonDecodingFormat
,OggJsonDecodingFormat
,OrcFileFormatFactory.OrcBulkDecodingFormat
,ParquetFileFormatFactory.ParquetBulkDecodingFormat
,PbDecodingFormat
,PbEncodingFormat
@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
orDynamicTableSink
). - 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
All Methods Instance Methods Abstract Methods Modifier and Type Method 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.
-
-