[beam] branch master updated (a666187 -> 4b77225)

[re...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

reuvenlax pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from a666187  Fix headings in downloads.md
     new 329c2e6  Beam-2535 : Pursue pull request 4700 with manual apply changes from current 4700 pull request into my branch. And apply required changes
     new f72a29a  Beam-2535 : Pursue pull request 4700 with manual apply changes from current 4700 pull request into my branch. And apply required changes
     new fd72944  Merge https://github.com/apache/beam into time-output-timestamp
     new 81621be  Beam-2535 : Pursue pull request 4700 with manual apply changes from current 4700 pull request into my branch. And apply required changes
     new 5249dd1  Beam-2535 : Replace timeStamp with outputTimeStamp
     new cab84c2  Beam-2535 : Apply Spotless
     new b0eb6f8  Merge branch 'master' into time-output-timestamp
     new 5aeeebf  Beam-2535 : Pass outputTimestamp param in onTimer method
     new 9926a01  Beam-2535 : Minor changed
     new 6f16562  [BEAM-2535] : Add Commit State in ParDoEvaluator
     new 1839319  Merge branch 'master' into time-output-timestamp
     new a8c65b8  [BEAM-2535] : Add outputTimestamp in compare method, Revert StatefulParDoEvaluatorFactory and WatermarkManager
     new b398447  Beam-2535 : Modifying default minimum target and GC time
     new 03625c9  Merge branch 'master' into time-output-timestamp
     new 0b5e231  Beam-2535 : Proposed changes
     new 47dce8a  Merge branch 'master' into time-output-timestamp
     new dffea11  BEAM-2535 : Removal of extra lines
     new da3001a  Merge branch 'time-output-timestamp' of https://github.com/xubii/beam into time-output-timestamp
     new d5a8b2d  Beam-2535 : Added original PR watermark hold functionality.
     new bacccdc  [Beam-2535] Variable renaming and added output timestamp in BufferedElements.java and BufferedElementDoFnRunner.java
     new b61b565  Merge branch 'master' into time-output-timestamp
     new cfa678e  Beam-2535 : Apply Spotless
     new 6e9ca40  Merge branch 'master' into time-output-timestamp
     new 71fbf10  [BEAM-2535] Apply Spotless
     new 8f02a43  Merge branch 'time-output-timestamp' of https://github.com/xubii/beam into time-output-timestamp
     new 11cbc0c  [Beam-2535] Modify test case
     new f10ba3f  [Beam-2535] Added comments
     new 6d04941  Merge branch 'master' into time-output-timestamp
     new 66eacdd  [Beam-2535] Apply Spotless
     new b29e04b  [Beam-2535] Set Processing Time with outputTimestamp
     new f85b889  [Beam-2535] Minor renaming
     new 7835912  [BEAM-2535] Revert Processing Time, Addition of OutputTimestamp
     new ee8a7f3  Merge branch 'master' into time-output-timestamp
     new 1bea195  [BEAM-2535] Revert TimerReceiver outputTimestamp
     new e540266  [BEAM-2535] Revert TimerReceiver outputTimestamp
     new 97c59de  Merge branch 'master' into time-output-timestamp
     new 9713ce0  Merge branch 'master' into time-output-timestamp
     new c1e284b  [BEAM-2535] Making OnTimer compatible
     new a3134ba  [BEAM-2535] Making OnTimer compatible
     new 396c89b  Adding OutputTimestamp in Timer Object
     new 0822c4e  Merge branch 'master' into time-output-timestamp
     new 7b386bf  Apply Spotless and checkstyle
     new c273b53  [Beam-2535] Added watermark functionality for the dataflow runner
     new 742d0bb  Merge branch 'master' into time-output-timestamp
     new 259c63c  [Beam-2535] Used boolean instead boxed type
     new e43547c  Merge branch 'master' into time-output-timestamp
     new 1950ad9  [Beam-2535] Modify required watermark hold functionality
     new 465fa57  EarliestTimestamp Fix for outputTimestamp
     new a94327b  Merge branch 'master' into time-output-timestamp
     new 21539d5  Merge branch 'master' into time-output-timestamp
     new 7c8369d  Merge branch 'master' into time-output-timestamp
     new 83d90fd  Rebase TimerData PR
     new 7d60044  Update ParDoTest.java
     new 2565959  Merge master into time-output-timestamp
     new 2ea7bab  Apply spotless
     new 5e63afd  Compilation Fix PardoTest
     new 80862f2  Reverting outputTimestamp validation
     new 149dec2  CheckStyle Fix
     new 6fdb1e1  Adding Category to exclude Flink Runner
     new 4b77225  Merge pull request #9677 from xubii/time-output-timestamp

The 24995 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../operators/ApexTimerInternalsTest.java          | 12 ++-
 .../beam/runners/core/construction/Timer.java      |  1 +
 .../apache/beam/runners/core/SimpleDoFnRunner.java | 86 +++++++++++++++-------
 .../beam/runners/core/StatefulDoFnRunner.java      |  2 +-
 .../apache/beam/runners/core/TimerInternals.java   | 31 ++++++--
 .../direct/StatefulParDoEvaluatorFactory.java      | 62 +++++++++++++++-
 .../beam/runners/direct/WatermarkManager.java      |  5 +-
 runners/flink/flink_runner.gradle                  |  1 +
 .../dataflow/worker/WindmillTimerInternals.java    |  2 +-
 .../main/java/org/apache/beam/sdk/state/Timer.java |  6 ++
 ...java => UsesTestStreamWithOutputTimestamp.java} |  6 +-
 .../org/apache/beam/sdk/transforms/ParDoTest.java  | 79 ++++++++++++++++++++
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    |  5 ++
 13 files changed, 251 insertions(+), 47 deletions(-)
 copy sdks/java/core/src/main/java/org/apache/beam/sdk/testing/{UsesFailureMessage.java => UsesTestStreamWithOutputTimestamp.java} (78%)