You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/04/20 21:19:40 UTC
[2/2] beam git commit: [BEAM-1786,
BEAM-1871] Add the ability to register coder factories
[BEAM-1786, BEAM-1871] Add the ability to register coder factories
This closes #2605
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/36a12d02
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/36a12d02
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/36a12d02
Branch: refs/heads/master
Commit: 36a12d02371b2fdc216a9b7f7bf1b3ff11c2c53b
Parents: b47fd52 3c811f5
Author: Luke Cwik <lc...@google.com>
Authored: Thu Apr 20 14:19:31 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Thu Apr 20 14:19:31 2017 -0700
----------------------------------------------------------------------
.../org/apache/beam/runners/core/StateTags.java | 6 +-
.../beam/runners/core/ReduceFnTester.java | 12 +--
.../apache/beam/runners/core/StateTagTest.java | 3 +-
.../spark/translation/SparkRuntimeContext.java | 3 +-
sdks/java/core/pom.xml | 5 -
.../main/java/org/apache/beam/sdk/Pipeline.java | 3 +-
.../apache/beam/sdk/coders/CoderFactories.java | 22 +++-
.../apache/beam/sdk/coders/CoderRegistrar.java | 45 ++++++++
.../apache/beam/sdk/coders/CoderRegistry.java | 108 ++++++++++++++-----
.../apache/beam/sdk/coders/StringUtf8Coder.java | 2 +-
.../beam/sdk/coders/TableRowJsonCoder.java | 88 ---------------
.../apache/beam/sdk/util/state/StateSpecs.java | 6 +-
.../org/apache/beam/SdkCoreApiSurfaceTest.java | 1 -
.../beam/sdk/coders/CoderRegistryTest.java | 77 +++++++------
.../beam/sdk/coders/DefaultCoderTest.java | 8 +-
.../beam/sdk/coders/TableRowJsonCoderTest.java | 94 ----------------
.../beam/sdk/transforms/LatestFnTest.java | 2 +-
.../org/apache/beam/sdk/transforms/SumTest.java | 2 +-
.../transforms/reflect/DoFnInvokersTest.java | 4 +-
sdks/java/io/google-cloud-platform/pom.xml | 5 +
.../io/gcp/bigquery/BigQueryCoderRegistrar.java | 39 +++++++
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 1 -
.../sdk/io/gcp/bigquery/BigQuerySourceBase.java | 1 -
.../io/gcp/bigquery/StreamingWriteTables.java | 1 -
.../sdk/io/gcp/bigquery/TableRowInfoCoder.java | 1 -
.../sdk/io/gcp/bigquery/TableRowJsonCoder.java | 91 ++++++++++++++++
.../sdk/io/gcp/bigquery/TableRowWriter.java | 1 -
.../bigquery/BigQueryCoderRegistrarTest.java | 40 +++++++
.../sdk/io/gcp/bigquery/BigQueryIOTest.java | 1 -
.../io/gcp/bigquery/FakeBigQueryServices.java | 1 -
.../sdk/io/gcp/bigquery/FakeJobService.java | 1 -
.../io/gcp/bigquery/TableRowJsonCoderTest.java | 95 ++++++++++++++++
32 files changed, 479 insertions(+), 290 deletions(-)
----------------------------------------------------------------------