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 8152b98 Merge pull request #14102 from pabloem/try-dash
add 6308ef9 Merge pull request #13802: [BEAM-1474]. Adding MapState and
SetState support for the Dataflow runner
No new revisions were added by this update.
Summary of changes:
.../examples/cookbook/MapClassIntegrationIT.java | 71 +++
.../beam/runners/core/InMemoryStateInternals.java | 44 +-
.../org/apache/beam/runners/core/StateTags.java | 6 +
.../beam/runners/core/StateInternalsTest.java | 2 +-
.../streaming/state/FlinkStateInternals.java | 63 ++-
runners/google-cloud-dataflow-java/build.gradle | 2 -
.../dataflow/BatchStatefulParDoOverrides.java | 16 +-
.../dataflow/DataflowPipelineTranslator.java | 7 +-
.../beam/runners/dataflow/DataflowRunner.java | 54 ++-
.../beam/runners/dataflow/DataflowRunnerTest.java | 21 +-
.../dataflow/worker/WindmillStateInternals.java | 510 ++++++++++++++++++++-
.../dataflow/worker/WindmillStateReader.java | 188 ++++++--
.../worker/WindmillStateInternalsTest.java | 394 ++++++++++++++++
.../dataflow/worker/WindmillStateReaderTest.java | 138 ++++++
.../worker/windmill/src/main/proto/windmill.proto | 26 ++
.../samza/runtime/SamzaStoreStateInternals.java | 48 +-
.../java/org/apache/beam/sdk/state/MapState.java | 52 ++-
.../java/org/apache/beam/sdk/state/StateSpecs.java | 24 +
18 files changed, 1558 insertions(+), 108 deletions(-)
create mode 100644
examples/java/src/test/java/org/apache/beam/examples/cookbook/MapClassIntegrationIT.java
