This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8317426 [FLINK-19990][table-planner-blink] MultipleInput
isChainableSource now considers DataStreamScanProvider
add edec6aa [FLINK-18774][debezium-avro] Support debezium avro format
add bff7da1 [FLINK-18774][debezium-avro] Improve debezium-avro format
implementation
No new revisions were added by this update.
Summary of changes:
.../confluent/RegistryAvroFormatFactory.java | 2 +-
.../DebeziumAvroDeserializationSchema.java | 199 +++++++++++++++++++
.../DebeziumAvroFormatFactory.java} | 78 ++++----
.../debezium/DebeziumAvroSerializationSchema.java} | 93 +++++----
.../org.apache.flink.table.factories.Factory | 1 +
.../confluent/RegistryAvroFormatFactoryTest.java | 2 +-
.../RegistryAvroRowDataSeDeSchemaTest.java | 2 +-
.../debezium/DebeziumAvroFormatFactoryTest.java} | 109 +++++-----
.../debezium/DebeziumAvroSerDeSchemaTest.java | 220 +++++++++++++++++++++
.../src/test/resources/debezium-avro-delete.avro | Bin 0 -> 147 bytes
.../src/test/resources/debezium-avro-insert.avro | Bin 0 -> 143 bytes
.../src/test/resources/debezium-avro-update.avro | Bin 0 -> 188 bytes
.../src/test/resources/debezium-test-schema.json | 191 ++++++++++++++++++
.../flink/formats/avro/AvroFileFormatFactory.java | 2 +-
.../avro/AvroRowDataSerializationSchema.java | 2 +-
.../formats/avro/RowDataToAvroConverters.java | 62 +++---
.../json/debezium/DebeziumJsonFormatFactory.java | 9 +
.../debezium/DebeziumJsonFormatFactoryTest.java | 41 +++-
pom.xml | 2 +
19 files changed, 843 insertions(+), 172 deletions(-)
create mode 100644
flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroDeserializationSchema.java
copy
flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/{RegistryAvroFormatFactory.java
=> debezium/DebeziumAvroFormatFactory.java} (70%)
copy
flink-formats/{flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonSerializationSchema.java
=>
flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroSerializationSchema.java}
(50%)
copy
flink-formats/{flink-json/src/test/java/org/apache/flink/formats/json/maxwell/MaxwellJsonFormatFactoryTest.java
=>
flink-avro-confluent-registry/src/test/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroFormatFactoryTest.java}
(62%)
create mode 100644
flink-formats/flink-avro-confluent-registry/src/test/java/org/apache/flink/formats/avro/registry/confluent/debezium/DebeziumAvroSerDeSchemaTest.java
create mode 100644
flink-formats/flink-avro-confluent-registry/src/test/resources/debezium-avro-delete.avro
create mode 100644
flink-formats/flink-avro-confluent-registry/src/test/resources/debezium-avro-insert.avro
create mode 100644
flink-formats/flink-avro-confluent-registry/src/test/resources/debezium-avro-update.avro
create mode 100644
flink-formats/flink-avro-confluent-registry/src/test/resources/debezium-test-schema.json
