Francisco Morillo created FLINK-39141:
-----------------------------------------
Summary: Support AWS Glue Schema Registry JSON for Table API
Key: FLINK-39141
URL: https://issues.apache.org/jira/browse/FLINK-39141
Project: Flink
Issue Type: Improvement
Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
Reporter: Francisco Morillo
Fix For: aws-connector-6.0.0
The existing flink-json-glue-schema-registry module supports JSON
serialization/deserialization with AWS Glue Schema Registry at the DataStream
API level, but does not include a Table API / SQL format factory.
This adds a GlueSchemaRegistryJsonFormatFactory so users can use 'format' =
'json-glue' in CREATE TABLE statements to read and write JSON data through GSR.
This is the JSON counterpart to FLINK-24379 (Avro format factory). It reuses
the shared config infrastructure (GlueFormatOptions, GlueFormatConfigBuilder)
introduced in that PR.
Includes:
- GlueSchemaRegistryJsonFormatFactory (DeserializationFormatFactory +
SerializationFormatFactory)
- GsrJsonRowDataSerializationSchema / GsrJsonRowDataDeserializationSchema
- JsonSchemaConverter (derives JSON Schema from Flink RowType for GSR
registration)
- SQL packaging module (flink-sql-json-glue-schema-registry)
- Unit tests, property-based tests, integration tests with mock GSR facades
- E2E test scaffold
- Documentation (json-glue.md)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
