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 2018/11/12 22:07:27 UTC
[beam] branch master updated (194b976 -> 413d852)
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 194b976 Merge pull request #7011 from markflyhigh/py-fix-py3-2
add 413d852 [BEAM-5446] SplittableDoFn: Remove "internal" methods for public API surface (#6467)
No new revisions were added by this update.
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 | 17 ++--
.../core/SplittableProcessElementInvoker.java | 7 +-
...BoundedSplittableProcessElementInvokerTest.java | 35 +++----
.../runners/core/SplittableParDoProcessFnTest.java | 37 ++++----
.../SplittableProcessElementsEvaluatorFactory.java | 20 ++--
.../flink/FlinkStreamingTransformTranslators.java | 7 +-
.../wrappers/streaming/SplittableDoFnOperator.java | 4 +-
.../dataflow/DataflowPipelineTranslatorTest.java | 4 +-
.../java/org/apache/beam/sdk/transforms/DoFn.java | 16 ++--
.../java/org/apache/beam/sdk/transforms/Watch.java | 2 +-
.../beam/sdk/transforms/reflect/DoFnInvoker.java | 2 +-
.../sdk/transforms/reflect/DoFnSignatures.java | 29 +-----
.../splittabledofn/ByteKeyRangeTracker.java | 10 +-
.../splittabledofn/OffsetRangeTracker.java | 10 +-
.../splittabledofn/RestrictionTracker.java | 51 +---------
.../sdk/transforms/reflect/DoFnInvokersTest.java | 15 +--
.../reflect/DoFnSignaturesSplittableDoFnTest.java | 46 +++++----
.../sdk/fn/splittabledofn/RestrictionTrackers.java | 104 +++++++++++++++++++++
.../beam/sdk/fn/splittabledofn}/package-info.java | 7 +-
.../fn/splittabledofn/RestrictionTrackersTest.java | 84 +++++++++++++++++
.../harness/SplittableProcessElementsRunner.java | 11 +--
.../beam/sdk/io/hbase/HBaseReadSplittableDoFn.java | 4 +-
28 files changed, 346 insertions(+), 230 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