This is an automated email from the ASF dual-hosted git repository.
apilloud pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 73642eb Merge pull request #9268: [BEAM-7738] Add external transform
support to PubsubIO
add a365c67 Combine serializer and deserializer
add d335596 Pass along exception
add 1239781 expose of method
add 6f9e11a fixup!
add 0cf8ae8 Merge incorrectly split strings
add 9f8fdd1 Merge pull request #9757: [BEAM-8484]
RowJsonDeserializer/ToJson cleanup
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/sdk/transforms/JsonToRow.java | 2 +-
.../org/apache/beam/sdk/transforms/ToJson.java | 8 +-
.../java/org/apache/beam/sdk/util/RowJson.java | 359 +++++++++++++++++++++
.../apache/beam/sdk/util/RowJsonDeserializer.java | 271 ----------------
.../apache/beam/sdk/util/RowJsonSerializer.java | 111 -------
.../org/apache/beam/sdk/util/RowJsonUtils.java | 13 +-
.../apache/beam/sdk/util/RowJsonValidation.java | 2 +-
.../beam/sdk/util/RowJsonValueExtractors.java | 2 +-
.../java/org/apache/beam/sdk/util/RowJsonTest.java | 14 +-
.../meta/provider/pubsub/PubsubMessageToRow.java | 4 +-
10 files changed, 384 insertions(+), 402 deletions(-)
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/util/RowJson.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/util/RowJsonDeserializer.java
delete mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/util/RowJsonSerializer.java
