[BEAM-2165] Update Dataflow to support serializing/deserializing custom user types configured via Jackson modules
This closes #2881 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/749b33f0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/749b33f0 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/749b33f0 Branch: refs/heads/master Commit: 749b33f0b74a9bcd3daf03ea7f9b4579baec2651 Parents: 02b72d6 e5729b5 Author: Luke Cwik <[email protected]> Authored: Thu May 4 07:27:17 2017 -0700 Committer: Luke Cwik <[email protected]> Committed: Thu May 4 07:27:17 2017 -0700 ---------------------------------------------------------------------- .../dataflow/DataflowPipelineTranslator.java | 13 ++- .../DataflowPipelineTranslatorTest.java | 83 ++++++++++++++++++++ .../options/DataflowProfilingOptionsTest.java | 4 +- .../DataflowWorkerLoggingOptionsTest.java | 4 +- .../apache/beam/sdk/options/ValueProviders.java | 4 +- .../apache/beam/sdk/testing/TestPipeline.java | 4 +- .../sdk/options/PipelineOptionsFactoryTest.java | 2 +- .../sdk/options/ProxyInvocationHandlerTest.java | 4 +- .../beam/sdk/options/ValueProviderTest.java | 19 +++-- .../beam/sdk/options/ValueProvidersTest.java | 19 ++--- .../beam/sdk/testing/TestPipelineTest.java | 6 +- .../gcp/options/GoogleApiDebugOptionsTest.java | 8 +- .../org/apache/beam/fn/harness/FnHarness.java | 5 +- .../beam/runners/core/BeamFnDataReadRunner.java | 2 - .../runners/core/BeamFnDataWriteRunner.java | 2 - .../control/ProcessBundleHandlerTest.java | 2 - .../runners/core/BeamFnDataReadRunnerTest.java | 2 - .../runners/core/BeamFnDataWriteRunnerTest.java | 2 - 18 files changed, 143 insertions(+), 42 deletions(-) ----------------------------------------------------------------------
