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/02/05 18:23:29 UTC
[beam] branch master updated (4c92739 -> c0bec87)

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 4c92739  Merge pull request #10774: Fix AvroIO javadoc for deprecated methods
     add c0bec87  [BEAM-5605] Migrate splittable DoFn methods to use "new" DoFn style argument providing. (#10702)

No new revisions were added by this update.

Summary of changes:
 .../runners/core/construction/SplittableParDo.java |  65 ++-
 .../construction/SplittableParDoNaiveBounded.java  |  25 +-
 .../core/construction/PTransformMatchersTest.java  |   4 +-
 .../core/construction/ParDoTranslationTest.java    |   4 +-
 .../core/construction/SplittableParDoTest.java     |   4 +-
 .../graph/SplittableParDoExpanderTest.java         |   6 +-
 ...TimeBoundedSplittableProcessElementInvoker.java |   5 +
 .../apache/beam/runners/core/SimpleDoFnRunner.java |  21 +
 .../core/SplittableParDoViaKeyedWorkItems.java     |  14 +-
 ...BoundedSplittableProcessElementInvokerTest.java |   6 +-
 .../runners/core/SplittableParDoProcessFnTest.java |  12 +-
 .../dataflow/DataflowPipelineTranslatorTest.java   |   2 +-
 .../java/org/apache/beam/sdk/transforms/DoFn.java  | 169 +++++--
 .../org/apache/beam/sdk/transforms/DoFnTester.java |   6 +
 .../java/org/apache/beam/sdk/transforms/Watch.java |  10 +-
 .../reflect/ByteBuddyDoFnInvokerFactory.java       | 103 ++++-
 .../beam/sdk/transforms/reflect/DoFnInvoker.java   | 273 ++++++++---
 .../beam/sdk/transforms/reflect/DoFnSignature.java |  71 ++-
 .../sdk/transforms/reflect/DoFnSignatures.java     | 510 ++++++++++++---------
 .../splittabledofn/RestrictionTracker.java         |   4 +-
 .../beam/sdk/transforms/SplittableDoFnTest.java    |  26 +-
 .../sdk/transforms/reflect/DoFnInvokersTest.java   | 130 ++++--
 .../reflect/DoFnSignaturesSplittableDoFnTest.java  | 262 ++++++++---
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    | 245 +++++-----
 .../beam/fn/harness/FnApiDoFnRunnerTest.java       |   7 +-
 .../beam/sdk/io/hbase/HBaseReadSplittableDoFn.java |   8 +-
 26 files changed, 1362 insertions(+), 630 deletions(-)