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 2019/12/23 19:56:46 UTC
[beam] branch master updated (a8ab29c -> b4f0297)

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 a8ab29c  [BEAM-8846] Update documentation about stream observers and factories, stating that they are thread safe. (#10242)
     add b4f0297  [BEAM-7951] Allow runner to configure customization WindowedValue coder. (#9979)

No new revisions were added by this update.

Summary of changes:
 .../beam/model/fnexecution/v1/standard_coders.yaml |  38 ++++
 .../pipeline/src/main/proto/beam_runner_api.proto  |  28 +++
 .../core/construction/CoderTranslators.java        |  20 +++
 .../core/construction/ModelCoderRegistrar.java     |   5 +
 .../runners/core/construction/ModelCoders.java     |  18 +-
 .../core/construction/graph/ExecutableStage.java   |  29 +++-
 .../construction/graph/GreedyPipelineFuser.java    |   3 +-
 .../core/construction/graph/GreedyStageFuser.java  |   4 +-
 .../graph/ImmutableExecutableStage.java            |  23 ++-
 .../construction/graph/OutputDeduplicator.java     |   3 +-
 .../core/construction/CoderTranslationTest.java    |   2 +
 .../runners/core/construction/CommonCoderTest.java |   9 +-
 .../construction/graph/ExecutableStageTest.java    |   4 +-
 .../graph/ImmutableExecutableStageTest.java        |   4 +-
 .../construction/graph/OutputDeduplicatorTest.java |  25 ++-
 .../graph/CreateExecutableStageNodeFunction.java   |   4 +-
 .../control/ProcessBundleDescriptors.java          |  38 ++--
 .../beam/runners/fnexecution/wire/WireCoders.java  |  56 +++++-
 .../BatchSideInputHandlerFactoryTest.java          |   4 +-
 .../org/apache/beam/sdk/util/WindowedValue.java    | 191 +++++++++++++++++++++
 .../apache/beam/sdk/util/WindowedValueTest.java    |   6 +
 sdks/python/apache_beam/coders/coder_impl.pxd      |   7 +
 sdks/python/apache_beam/coders/coder_impl.py       |  49 ++++++
 sdks/python/apache_beam/coders/coders.py           |  46 ++++-
 .../apache_beam/coders/coders_test_common.py       |  56 ++++++
 .../apache_beam/coders/standard_coders_test.py     |  12 ++
 sdks/python/apache_beam/utils/windowed_value.py    |   9 +
 27 files changed, 649 insertions(+), 44 deletions(-)