You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by am...@apache.org on 2021/03/09 18:45:15 UTC
[beam] branch master updated (4e7d645 -> b55dd49)

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