beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From reuven...@apache.org
Subject [beam] 01/01: Merge pull request #12474: [BEAM-10650] OrderedListState API
Date Sat, 08 Aug 2020 20:29:57 GMT
This is an automated email from the ASF dual-hosted git repository.

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

commit edb42952f6b0aa99477f5c7baca6d6a0d93deb4f
Merge: 7fbc09e 9d0d0b0
Author: reuvenlax <relax@google.com>
AuthorDate: Sat Aug 8 13:29:31 2020 -0700

    Merge pull request #12474: [BEAM-10650] OrderedListState API

 .../pipeline/src/main/proto/beam_runner_api.proto  |   5 +
 .../core/construction/ParDoTranslation.java        |   9 ++
 .../beam/runners/core/InMemoryStateInternals.java  | 100 ++++++++++++-
 .../org/apache/beam/runners/core/StateTag.java     |   3 +
 .../org/apache/beam/runners/core/StateTags.java    |  11 ++
 .../direct/CopyOnAccessInMemoryStateInternals.java |  22 +++
 runners/flink/flink_runner.gradle                  |   1 +
 runners/flink/job-server/flink_job_server.gradle   |   2 +
 .../state/FlinkBroadcastStateInternals.java        |   8 +
 .../streaming/state/FlinkStateInternals.java       |  15 ++
 runners/google-cloud-dataflow-java/build.gradle    |   1 +
 .../beam/runners/dataflow/DataflowRunner.java      |   7 +
 .../dataflow/worker/WindmillStateInternals.java    |  93 +++++++++++-
 .../worker/windmill/src/main/proto/windmill.proto  |  59 ++++++++
 runners/jet/build.gradle                           |   1 +
 runners/portability/java/build.gradle              |   1 +
 runners/samza/build.gradle                         |   1 +
 .../samza/runtime/SamzaStoreStateInternals.java    |   8 +
 runners/spark/build.gradle                         |   2 +
 runners/spark/job-server/build.gradle              |   1 +
 .../spark/stateful/SparkStateInternals.java        |   8 +
 .../apache/beam/sdk/state/OrderedListState.java    |  55 +++++++
 .../org/apache/beam/sdk/state/StateBinder.java     |   3 +
 .../org/apache/beam/sdk/state/StateKeySpec.java    |  39 +++++
 .../java/org/apache/beam/sdk/state/StateSpec.java  |   2 +
 .../java/org/apache/beam/sdk/state/StateSpecs.java |  64 ++++++++
 .../beam/sdk/testing/UsesOrderedListState.java     |  25 ++++
 .../java/org/apache/beam/sdk/transforms/ParDo.java |   5 +
 .../sdk/transforms/reflect/DoFnSignatures.java     |   5 +
 .../org/apache/beam/sdk/transforms/ParDoTest.java  | 166 +++++++++++++++++++++
 .../beam/fn/harness/state/FnApiStateAccessor.java  |   8 +
 31 files changed, 728 insertions(+), 2 deletions(-)



Mime
View raw message