Details
-
New Feature
-
Status: Closed
-
Major
-
Resolution: Implemented
-
None
-
None
-
None
Description
A lot of work went into creating unified interfaces for source, sinks, formats. FLINK-8240, FLINK-8866, FLINK-8558, FLINK-9852 have been merged. We can now add more table factories for different connectors and formats including descriptors for specifying them programmatically. This issue is an umbrella issues for tracking all efforts about table descriptors and table factories.
Attachments
Issue Links
- is blocked by
-
FLINK-8558 Add unified format interfaces and format discovery
- Resolved
1.
|
Improve CSVTableSourceFactory to support all descriptor properties | Closed | Unassigned | |||||||||
2.
|
Add a Kafka table source factory with Avro format support | Resolved | Xingcan Cui | |||||||||
3.
|
Add a Kafka table source factory with JSON format support | Resolved | Xingcan Cui | |||||||||
4.
|
Add a Kafka table source factory with Protobuf format support | Closed | Unassigned | |||||||||
5.
|
Add a single value table format factory | Closed | Ruidong Li |
|
||||||||
6.
|
Add a CSV table format factory | Closed | Jiayi Liao |
|
||||||||
7.
|
Support schema derivation in Avro table format factory | Closed | Unassigned | |||||||||
8.
|
Support a custom FlinkKafkaPartitioner for a Kafka table sink factory | Resolved | Timo Walther | |||||||||
9.
|
Add a byte array table format factory | Closed | Unassigned | |||||||||
10.
|
Support keyed formats for Kafka table source sink factory | Resolved | Unassigned |