This is an automated email from the ASF dual-hosted git repository.
scwhittle pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 5d658c1e867 [Dataflow Streaming] Improve logs (#37152)
add dfe01c0f092 Add WindmillTagEncoding Interface (#37150)
No new revisions were added by this update.
Summary of changes:
.../worker/StreamingModeExecutionContext.java | 37 +++---
.../dataflow/worker/WindmillKeyedWorkItem.java | 16 +--
.../dataflow/worker/WindmillTimerInternals.java | 18 +--
.../dataflow/worker/WindowingWindmillReader.java | 8 +-
.../worker/windmill/state/CachingStateTable.java | 29 +++--
.../windmill/state/WindmillCombiningState.java | 4 +-
.../windmill/state/WindmillStateInternals.java | 4 +-
.../worker/windmill/state/WindmillTagEncoding.java | 131 +++++++++++++++++++++
...tateTagUtil.java => WindmillTagEncodingV1.java} | 101 ++--------------
.../worker/StreamingGroupAlsoByWindowFnsTest.java | 12 +-
...reamingGroupAlsoByWindowsReshuffleDoFnTest.java | 9 +-
.../dataflow/worker/WindmillKeyedWorkItemTest.java | 42 +++++--
.../windmill/state/WindmillStateCacheTest.java | 16 +--
.../windmill/state/WindmillStateInternalsTest.java | 8 +-
...tilTest.java => WindmillTagEncodingV1Test.java} | 22 ++--
15 files changed, 279 insertions(+), 178 deletions(-)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillTagEncoding.java
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/{WindmillStateTagUtil.java
=> WindmillTagEncodingV1.java} (73%)
rename
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/state/{WindmillStateTagUtilTest.java
=> WindmillTagEncodingV1Test.java} (93%)
