This resolves #1988: Add full-fidelity conversion to/from Java SDK triggers and Runner API protos
Upgrade Dataflow container version to beam-master-20170214 Remove underscore from Runner API proto Java package Add conversion to/from Java SDK trigger to runner API proto Add runner API config to poms Flesh out triggers in Runner API proto Fix typo in runner API generated Java class Upgrade Java triggers to support runner API deserialization Reify delay and alignment in AfterProcessingTime transform Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/db19c7df Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/db19c7df Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/db19c7df Branch: refs/heads/master Commit: db19c7df50294dd5697822d3f4038211797383d7 Parents: 9061c65 e097b75 Author: Kenneth Knowles <[email protected]> Authored: Tue Feb 14 20:51:00 2017 -0800 Committer: Kenneth Knowles <[email protected]> Committed: Tue Feb 14 20:51:00 2017 -0800 ---------------------------------------------------------------------- pom.xml | 8 + .../AfterDelayFromFirstElementStateMachine.java | 4 +- .../AfterProcessingTimeStateMachine.java | 2 + ...rSynchronizedProcessingTimeStateMachine.java | 7 +- .../core/triggers/TriggerStateMachines.java | 38 ++- ...chronizedProcessingTimeStateMachineTest.java | 3 +- .../core/triggers/TriggerStateMachinesTest.java | 7 +- runners/google-cloud-dataflow-java/pom.xml | 2 +- .../src/main/proto/beam_runner_api.proto | 111 +++++-- sdks/java/core/pom.xml | 5 + .../beam/sdk/transforms/windowing/AfterAll.java | 7 + .../windowing/AfterDelayFromFirstElement.java | 240 -------------- .../sdk/transforms/windowing/AfterEach.java | 7 + .../sdk/transforms/windowing/AfterFirst.java | 7 + .../windowing/AfterProcessingTime.java | 105 +++++-- .../AfterSynchronizedProcessingTime.java | 31 +- .../windowing/TimestampTransform.java | 64 ++++ .../beam/sdk/transforms/windowing/Triggers.java | 313 +++++++++++++++++++ .../windowing/AfterProcessingTimeTest.java | 2 +- .../AfterSynchronizedProcessingTimeTest.java | 2 +- .../sdk/transforms/windowing/TriggersTest.java | 100 ++++++ 21 files changed, 738 insertions(+), 327 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/db19c7df/runners/google-cloud-dataflow-java/pom.xml ----------------------------------------------------------------------
