beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [3/3] beam git commit: This closes #2273: Add align and offset to Timer
Date Thu, 04 May 2017 20:27:52 GMT
This closes #2273: Add align and offset to Timer

  Fix initial watermark of DoFnOperator in Flink runner
  [BEAM-1727] Add align and offset to Timer


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9fffa7ef
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9fffa7ef
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9fffa7ef

Branch: refs/heads/master
Commit: 9fffa7efac634eebecf802626c6d7c88e3d60be5
Parents: e2aa889 7ece164
Author: Kenneth Knowles <klk@google.com>
Authored: Thu May 4 13:27:27 2017 -0700
Committer: Kenneth Knowles <klk@google.com>
Committed: Thu May 4 13:27:27 2017 -0700

----------------------------------------------------------------------
 .../construction/PTransformMatchersTest.java    |   2 +-
 .../beam/runners/core/SimpleDoFnRunner.java     |  44 +++++++-
 .../beam/runners/core/SimpleDoFnRunnerTest.java |   2 +-
 .../wrappers/streaming/DoFnOperator.java        |  20 +++-
 .../org/apache/beam/sdk/transforms/DoFn.java    |   2 +-
 .../java/org/apache/beam/sdk/util/Timer.java    |  27 +++--
 .../apache/beam/sdk/transforms/ParDoTest.java   | 113 ++++++++++++++++++-
 7 files changed, 185 insertions(+), 25 deletions(-)
----------------------------------------------------------------------



Mime
View raw message