This closes #1190: Use strings for ids in Fn API
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2c71354d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2c71354d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2c71354d Branch: refs/heads/master Commit: 2c71354d0a337151fd53dc7eaeace439bcbd41ef Parents: 4f56acb 9933f27 Author: Kenneth Knowles <k...@google.com> Authored: Thu Feb 23 18:27:28 2017 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Thu Feb 23 18:27:28 2017 -0800 ---------------------------------------------------------------------- .../fn-api/src/main/proto/beam_fn_api.proto | 48 +++++----- .../fn/harness/control/BeamFnControlClient.java | 3 +- .../harness/control/ProcessBundleHandler.java | 8 +- .../fn/harness/control/RegisterHandler.java | 8 +- .../BeamFnDataBufferingOutboundObserver.java | 4 +- .../beam/fn/harness/data/BeamFnDataClient.java | 4 +- .../fn/harness/data/BeamFnDataGrpcClient.java | 4 +- .../harness/data/BeamFnDataGrpcMultiplexer.java | 11 +-- .../fn/harness/logging/BeamFnLoggingClient.java | 4 +- .../beam/runners/core/BeamFnDataReadRunner.java | 4 +- .../runners/core/BeamFnDataWriteRunner.java | 4 +- .../apache/beam/fn/harness/FnHarnessTest.java | 8 +- .../control/BeamFnControlClientTest.java | 12 +-- .../control/ProcessBundleHandlerTest.java | 95 ++++++++++---------- .../fn/harness/control/RegisterHandlerTest.java | 18 ++-- ...BeamFnDataBufferingOutboundObserverTest.java | 9 +- .../harness/data/BeamFnDataGrpcClientTest.java | 21 +++-- .../data/BeamFnDataGrpcMultiplexerTest.java | 12 +-- .../data/BeamFnDataInboundObserverTest.java | 4 +- .../runners/core/BeamFnDataReadRunnerTest.java | 8 +- .../runners/core/BeamFnDataWriteRunnerTest.java | 8 +- 21 files changed, 159 insertions(+), 138 deletions(-) ----------------------------------------------------------------------
