This is an automated email from the ASF dual-hosted git repository.
bhulette pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 46c226e Merge pull request #13077 [BEAM-9561] Dataframe test
infrastructure improvements.
add 376d2a6 [BEAM-10893] Add Json support to Kafka Table Provider (#12839)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
...mKafkaCSVTable.java => BeamKafkaJsonTable.java} | 62 ++++++++++------------
.../meta/provider/kafka/KafkaTableProvider.java | 5 +-
...bleCSVTest.java => BeamKafkaTableJsonTest.java} | 45 +++++++++++-----
...derCSVIT.java => KafkaTableProviderJsonIT.java} | 16 +++---
.../dsls/sql/extensions/create-external-table.md | 14 +++--
6 files changed, 84 insertions(+), 59 deletions(-)
copy
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/{BeamKafkaCSVTable.java
=> BeamKafkaJsonTable.java} (60%)
copy
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/{BeamKafkaTableCSVTest.java
=> BeamKafkaTableJsonTest.java} (51%)
copy
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/{KafkaTableProviderCSVIT.java
=> KafkaTableProviderJsonIT.java} (72%)
