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/04/02 15:36:50 UTC
[beam] branch master updated (ffea03a -> ab32135)
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 ffea03a Merge pull request #8197 from iemejia/BEAM-6968-mqtt-create-deprecate
new 8faffb2 Revert ": [BEAM-6352] Revert PR#6467 to fix Watch transform from swegner/revert_pr6467"
new 523b364 Update Watch transform to use a RestrictionTracker instead of a GrowthTracker in the fields.
new ab32135 [BEAM-6502] Re-Remove runner time execution information from public API surface (now including Watch)
The 20798 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../runners/apex/translation/ParDoTranslator.java | 8 +-
.../construction/SplittableParDoNaiveBounded.java | 5 +-
.../core/construction/PTransformMatchersTest.java | 3 +-
.../core/construction/SplittableParDoTest.java | 7 +-
runners/core-java/build.gradle | 1 +
...TimeBoundedSplittableProcessElementInvoker.java | 30 +-
.../core/SplittableParDoViaKeyedWorkItems.java | 24 +-
.../core/SplittableProcessElementInvoker.java | 7 +-
...BoundedSplittableProcessElementInvokerTest.java | 35 +-
.../runners/core/SplittableParDoProcessFnTest.java | 41 +-
.../SplittableProcessElementsEvaluatorFactory.java | 20 +-
.../flink/FlinkStreamingTransformTranslators.java | 7 +-
.../wrappers/streaming/SplittableDoFnOperator.java | 4 +-
.../dataflow/DataflowPipelineTranslatorTest.java | 4 +-
.../org/apache/beam/sdk/io/range/OffsetRange.java | 50 ++
.../java/org/apache/beam/sdk/transforms/DoFn.java | 16 +-
.../java/org/apache/beam/sdk/transforms/Watch.java | 751 +++++++++++----------
.../beam/sdk/transforms/reflect/DoFnInvoker.java | 2 +-
.../sdk/transforms/reflect/DoFnSignatures.java | 29 +-
.../splittabledofn/ByteKeyRangeTracker.java | 12 +-
.../splittabledofn/OffsetRangeTracker.java | 10 +-
.../splittabledofn/RestrictionTracker.java | 54 +-
.../beam/sdk/transforms/SplittableDoFnTest.java | 22 +-
.../org/apache/beam/sdk/transforms/WatchTest.java | 407 ++++-------
.../sdk/transforms/reflect/DoFnInvokersTest.java | 15 +-
.../reflect/DoFnSignaturesSplittableDoFnTest.java | 47 +-
.../sdk/fn/splittabledofn/RestrictionTrackers.java | 138 ++++
.../beam/sdk/fn/splittabledofn}/package-info.java | 7 +-
.../fn/splittabledofn/RestrictionTrackersTest.java | 156 +++++
.../harness/SplittableProcessElementsRunner.java | 11 +-
.../beam/sdk/io/hbase/HBaseReadSplittableDoFn.java | 4 +-
31 files changed, 1075 insertions(+), 852 deletions(-)
create mode 100644 sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java
copy sdks/java/{extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule => fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn}/package-info.java (82%)
create mode 100644 sdks/java/fn-execution/src/test/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackersTest.java