This is an automated email from the ASF dual-hosted git repository.
tvalentyn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from e56d1a1157b Enable missing-timeout pylint check (#28920)
add 9cdcb036cc9 move nested windmill state classes to top level files and
organize di… (#28506)
No new revisions were added by this update.
Summary of changes:
.../dataflow/worker/StreamingDataflowWorker.java | 2 +
.../worker/StreamingModeExecutionContext.java | 483 ++--
.../beam/runners/dataflow/worker/Weighers.java | 2 +-
.../dataflow/worker/WindmillStateInternals.java | 2830 --------------------
.../dataflow/worker/streaming/ActiveWorkState.java | 2 +-
.../worker/streaming/ComputationState.java | 2 +-
.../worker/windmill/state/CachingStateTable.java | 275 ++
.../worker/windmill/state/ConcatIterables.java | 55 +
.../dataflow/worker/windmill/state/IdTracker.java | 253 ++
.../worker/windmill/state/PagingIterable.java | 129 +
.../dataflow/worker/windmill/state/RangeCoder.java | 76 +
.../worker/windmill/state/RangeSetCoder.java | 46 +
.../state/SimpleWindmillState.java} | 33 +-
.../dataflow/worker/windmill/state/StateTag.java | 109 +
.../windmill/state/TimestampedValueWithId.java | 42 +
.../worker/windmill/state/ToIterableFunction.java | 79 +
.../windmill/state/ValuesAndContPosition.java | 46 +
.../state/WeightedList.java} | 45 +-
.../worker/windmill/state/WindmillBag.java | 209 ++
.../windmill/state/WindmillCombiningState.java | 170 ++
.../worker/windmill/state/WindmillMap.java | 449 ++++
.../worker/windmill/state/WindmillMultimap.java | 732 +++++
.../worker/windmill/state/WindmillOrderedList.java | 305 +++
.../worker/windmill/state/WindmillSet.java | 146 +
.../worker/windmill/state/WindmillState.java | 68 +
.../{ => windmill/state}/WindmillStateCache.java | 338 +--
.../windmill/state/WindmillStateInternals.java | 171 ++
.../{ => windmill/state}/WindmillStateReader.java | 530 +---
.../worker/windmill/state/WindmillStateUtil.java | 51 +
.../worker/windmill/state/WindmillValue.java | 160 ++
.../windmill/state/WindmillWatermarkHold.java | 259 ++
.../worker/windmill/state/WrappedFuture.java | 64 +
.../worker/StreamingModeExecutionContextTest.java | 2 +
.../worker/streaming/ActiveWorkStateTest.java | 2 +-
.../state}/WindmillStateCacheTest.java | 135 +-
.../state}/WindmillStateInternalsTest.java | 282 +-
.../state}/WindmillStateReaderTest.java | 6 +-
37 files changed, 4677 insertions(+), 3911 deletions(-)
delete mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillStateInternals.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/CachingStateTable.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/ConcatIterables.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/IdTracker.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/PagingIterable.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/RangeCoder.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/RangeSetCoder.java
copy
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/{Weighers.java
=> windmill/state/SimpleWindmillState.java} (50%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/StateTag.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/TimestampedValueWithId.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/ToIterableFunction.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/ValuesAndContPosition.java
copy
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/{Weighers.java
=> windmill/state/WeightedList.java} (53%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillBag.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillCombiningState.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillMap.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillMultimap.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillOrderedList.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillSet.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillState.java
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/{
=> windmill/state}/WindmillStateCache.java (92%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillStateInternals.java
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/{
=> windmill/state}/WindmillStateReader.java (70%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillStateUtil.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillValue.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillWatermarkHold.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WrappedFuture.java
rename
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/{
=> windmill/state}/WindmillStateCacheTest.java (75%)
rename
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/{
=> windmill/state}/WindmillStateInternalsTest.java (97%)
rename
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/{
=> windmill/state}/WindmillStateReaderTest.java (99%)
