You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2020/05/21 03:13:32 UTC
[beam] branch master updated (9cf6f5f -> ffd74b0)

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

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


    from 9cf6f5f  Moving to 2.23.0-SNAPSHOT on master branch.
     add ffd74b0  [BEAM-10028] Add support for the state backed iterable coder to the Java SDK harness. (#11746)

No new revisions were added by this update.

Summary of changes:
 .../construction/AvroGenericCoderTranslator.java   |   4 +-
 .../core/construction/CoderTranslation.java        |  35 +++-
 .../runners/core/construction/CoderTranslator.java |   8 +-
 .../core/construction/CoderTranslators.java        |   9 +-
 .../core/construction/ModelCoderRegistrar.java     |  11 +-
 .../runners/core/construction/ModelCoders.java     |  12 +-
 .../core/construction/RehydratedComponents.java    |   4 +-
 .../core/construction/CoderTranslationTest.java    |   5 +-
 .../runners/core/construction/CommonCoderTest.java |   3 +-
 .../core/construction/ParDoTranslationTest.java    |   4 +-
 .../core/construction/PipelineTranslationTest.java |   5 +-
 .../beam/runners/dataflow/DataflowRunner.java      |   4 +-
 .../dataflow/worker/FnApiWindowMappingFn.java      |   9 +-
 .../apache/beam/sdk/coders/IterableLikeCoder.java  |  22 +-
 .../util/BufferedElementCountingOutputStream.java  |  14 +-
 .../BufferedElementCountingOutputStreamTest.java   |  16 +-
 .../sdk/expansion/service/ExpansionService.java    |   3 +-
 .../beam/fn/harness/BeamFnDataReadRunner.java      |  18 +-
 .../beam/fn/harness/BeamFnDataWriteRunner.java     |  26 ++-
 .../apache/beam/fn/harness/state/BagUserState.java |   2 +-
 .../beam/fn/harness/state/MultimapSideInput.java   |   6 +-
 .../beam/fn/harness/state/StateBackedIterable.java | 224 +++++++++++++++++++++
 .../fn/harness/state/StateFetchingIterators.java   |   2 +-
 .../beam/fn/harness/BeamFnDataReadRunnerTest.java  |   1 +
 .../beam/fn/harness/BeamFnDataWriteRunnerTest.java |   3 +-
 .../beam/fn/harness/FnApiDoFnRunnerTest.java       |   7 +-
 .../fn/harness/state/StateBackedIterableTest.java  | 184 +++++++++++++++++
 27 files changed, 600 insertions(+), 41 deletions(-)
 create mode 100644 sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/StateBackedIterable.java
 create mode 100644 sdks/java/harness/src/test/java/org/apache/beam/fn/harness/state/StateBackedIterableTest.java