[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(-) ----------------------------------------------------------------------