|
|
|
FLINK-10017
|
FLINK-8535
Support keyed formats for Kafka table source sink factory
|
Unassigned
|
Timo Walther
|
|
Resolved |
Implemented
|
|
|
|
|
|
|
|
FLINK-9984
|
FLINK-8535
Add a byte array table format factory
|
Unassigned
|
Timo Walther
|
|
Closed |
Won't Fix
|
|
|
|
|
|
|
|
FLINK-9979
|
FLINK-8535
Support a custom FlinkKafkaPartitioner for a Kafka table sink factory
|
Timo Walther
|
Timo Walther
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-9965
|
FLINK-8535
Support schema derivation in Avro table format factory
|
Unassigned
|
Timo Walther
|
|
Closed |
Won't Fix
|
|
|
|
|
|
|
|
FLINK-9964
|
FLINK-8535
Add a CSV table format factory
|
Jiayi Liao
|
Timo Walther
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-9963
|
FLINK-8535
Add a single value table format factory
|
Ruidong Li
|
Timo Walther
|
|
Closed |
Duplicate
|
|
|
|
|
|
|
|
FLINK-9651
|
FLINK-8535
Add a Kafka table source factory with Protobuf format support
|
Unassigned
|
zhangminglei
|
|
Closed |
Duplicate
|
|
|
|
|
|
|
|
FLINK-8538
|
FLINK-8535
Add a Kafka table source factory with JSON format support
|
Xingcan Cui
|
Timo Walther
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-8537
|
FLINK-8535
Add a Kafka table source factory with Avro format support
|
Xingcan Cui
|
Timo Walther
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-8536
|
FLINK-8535
Improve CSVTableSourceFactory to support all descriptor properties
|
Unassigned
|
Timo Walther
|
|
Closed |
Won't Fix
|
|
|
|
|