[FLINK-8535] Implement a basic set of table factories

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Component/s: Table SQL / Legacy Planner
• Assignee: Unassigned
• Reporter: Timo Walther
• Created: 31/Jan/18 11:55
• Updated: 30/Apr/21 05:38
• Resolved: 30/Apr/21 05:38

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.

Issue Links

• is blocked by: FLINK-8558 Add unified format interfaces and format discovery

Sub-Tasks

• Improve CSVTableSourceFactory to support all descriptor properties: Closed
• Add a Kafka table source factory with Avro format support: Resolved
• Add a Kafka table source factory with JSON format support: Resolved
• Add a Kafka table source factory with Protobuf format support: Closed
• Add a single value table format factory: Closed
• Add a CSV table format factory: Closed
• Support schema derivation in Avro table format factory: Closed
• Support a custom FlinkKafkaPartitioner for a Kafka table sink factory: Resolved
• Add a byte array table format factory: Closed
• Support keyed formats for Kafka table source sink factory: Resolved