You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2019/11/02 02:09:21 UTC
[beam] branch master updated (9d2d9df -> 9b30d7c)
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 9d2d9df Merge pull request #9924 from davidcavazos/distinct-code
add 9b30d7c [BEAM-8146,BEAM-8204,BEAM-8205] Add equals and hashCode to SchemaCoder and RowCoder (#9493)
No new revisions were added by this update.
Summary of changes:
runners/apex/build.gradle | 6 +-
runners/flink/flink_runner.gradle | 3 -
.../util/SchemaCoderCloudObjectTranslator.java | 15 +-
.../runners/dataflow/util/CloudObjectsTest.java | 12 +-
.../java/org/apache/beam/sdk/coders/RowCoder.java | 7 +-
.../main/java/org/apache/beam/sdk/io/AvroIO.java | 2 +
.../apache/beam/sdk/schemas/AutoValueSchema.java | 59 ++---
.../apache/beam/sdk/schemas/AvroRecordSchema.java | 13 +-
.../apache/beam/sdk/schemas/CachingFactory.java | 18 ++
.../beam/sdk/schemas/FromRowUsingCreator.java | 30 ++-
.../sdk/schemas/GetterBasedSchemaProvider.java | 73 ++++-
.../apache/beam/sdk/schemas/JavaBeanSchema.java | 80 ++++--
.../apache/beam/sdk/schemas/JavaFieldSchema.java | 40 ++-
.../org/apache/beam/sdk/schemas/SchemaCoder.java | 46 +++-
.../beam/sdk/schemas/UserTypeCreatorFactory.java | 5 +-
.../beam/sdk/schemas/transforms/Convert.java | 1 +
.../sdk/schemas/transforms/SchemaAggregateFn.java | 4 +-
.../apache/beam/sdk/schemas/utils/AvroUtils.java | 21 +-
.../beam/sdk/schemas/utils/ConvertHelpers.java | 10 +-
.../org/apache/beam/sdk/testing/TestStream.java | 4 +-
.../org/apache/beam/sdk/transforms/Create.java | 24 +-
.../java/org/apache/beam/sdk/transforms/ParDo.java | 10 +-
.../apache/beam/sdk/util/SerializableUtils.java | 13 +
.../org/apache/beam/sdk/values/PCollection.java | 10 +-
.../beam/sdk/schemas/AutoValueSchemaTest.java | 31 +++
.../apache/beam/sdk/schemas/AvroSchemaTest.java | 16 ++
.../beam/sdk/schemas/JavaBeanSchemaTest.java | 13 +
.../beam/sdk/schemas/JavaFieldSchemaTest.java | 15 +-
.../apache/beam/sdk/schemas/SchemaCoderTest.java | 293 +++++++++++++++++++++
.../beam/sdk/schemas/transforms/ConvertTest.java | 8 +-
.../org/apache/beam/sdk/transforms/CreateTest.java | 2 +
.../beam/sdk/transforms/ParDoSchemaTest.java | 9 +
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 26 +-
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 10 +-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 2 +
.../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 5 +-
.../queries/sql/SqlBoundedSideInputJoin.java | 2 +
.../sdk/nexmark/queries/sql/SqlQuery0Test.java | 2 +
.../sdk/nexmark/queries/sql/SqlQuery1Test.java | 2 +
39 files changed, 765 insertions(+), 177 deletions(-)
create mode 100644 sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/SchemaCoderTest.java