Package org.apache.flink.table.examples.java.connectors

Class Summary

Class	Description
ChangelogCsvDeserializer	The ChangelogCsvDeserializer contains a simple parsing logic for converting bytes into Row of Integer and String with a RowKind.
ChangelogCsvFormat	The ChangelogCsvFormat is a decoding format that uses a DeserializationSchema during runtime.
ChangelogCsvFormatFactory	The ChangelogCsvFormatFactory translates format-specific options to a format.
ChangelogSocketExample	Example for implementing a custom DynamicTableSource and a DecodingFormat.
SocketDynamicTableFactory	The SocketDynamicTableFactory translates the catalog table to a table source.
SocketDynamicTableSource	The SocketDynamicTableSource is used during planning.
SocketSource	The SocketSource opens a socket and consumes bytes.
SocketSource.DummyCheckpoint	Placeholder because the SocketSource does not support fault-tolerance and thus does not require actual checkpointing.
SocketSource.DummySplit	Placeholder because the socket itself implicitly represents the only split and does not require an actual split object.