This is an automated email from the ASF dual-hosted git repository.
amaliujia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 4e7d645 [BEAM-11659] Allow Kafka sql table provider to have a nested
mode and raw binary payloads (#14016)
add b55dd49 [BEAM-11659] Implement Pub/Sub Lite Table Provider (#13920)
No new revisions were added by this update.
Summary of changes:
.../src/main/resources/beam/suppressions.xml | 1 +
.../java/org/apache/beam/sdk/schemas/Schema.java | 35 +++
.../beam/sdk/schemas/io/DeadLetteredTransform.java | 87 ++++++++
.../org/apache/beam/sdk/schemas/SchemaTest.java | 19 ++
.../sdk/schemas/io/DeadLetteredTransformTest.java | 102 +++++++++
.../PubsubLiteSubscriptionTable.java} | 63 +++---
.../pubsublite/PubsubLiteTableProvider.java | 219 +++++++++++++++++++
.../PubsubLiteTopicTable.java} | 60 +++---
.../sql/meta/provider/pubsublite/RowHandler.java | 171 +++++++++++++++
.../meta/provider/pubsublite}/package-info.java | 2 +-
.../pubsublite/PubsubLiteTableProviderTest.java | 239 +++++++++++++++++++++
.../meta/provider/pubsublite/RowHandlerTest.java | 237 ++++++++++++++++++++
12 files changed, 1169 insertions(+), 66 deletions(-)
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/DeadLetteredTransform.java
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/io/DeadLetteredTransformTest.java
copy
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/{seqgen/GenerateSequenceTable.java
=> pubsublite/PubsubLiteSubscriptionTable.java} (52%)
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsublite/PubsubLiteTableProvider.java
copy
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/{seqgen/GenerateSequenceTable.java
=> pubsublite/PubsubLiteTopicTable.java} (52%)
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsublite/RowHandler.java
copy sdks/java/{core/src/main/java/org/apache/beam/sdk/schemas/io =>
extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsublite}/package-info.java
(93%)
create mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsublite/PubsubLiteTableProviderTest.java
create mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsublite/RowHandlerTest.java
