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/04 20:45:31 UTC
[beam] branch master updated (5143d40 -> 1ed36b4)
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 5143d40 Merge pull request #10101: [BEAM-8662] Remove Py3 annotations support from MapTuple, FlatMapTuple
add 1b86686 [BEAM-4287] Add trySplit API to Java restriction tracker matching Python SDK definition.
add 8f09fc7 fixup!
add 3adc911 fixup!
add 1ed36b4 [BEAM-4287] Add trySplit API to Java restriction tracker matching Python SDK definition. Remove GetPartition()
No new revisions were added by this update.
Summary of changes:
.../construction/SplittableParDoNaiveBounded.java | 2 +-
.../core/construction/SplittableParDoTest.java | 5 +--
...TimeBoundedSplittableProcessElementInvoker.java | 6 +++-
.../runners/core/SplittableParDoProcessFnTest.java | 5 +--
.../java/org/apache/beam/sdk/transforms/DoFn.java | 37 ---------------------
.../java/org/apache/beam/sdk/transforms/Watch.java | 8 +++--
.../splittabledofn/ByteKeyRangeTracker.java | 11 ++++---
.../splittabledofn/OffsetRangeTracker.java | 7 ++--
.../splittabledofn/RestrictionTracker.java | 38 ++++++++++++++++------
.../beam/sdk/transforms/splittabledofn/Sizes.java | 9 +----
.../transforms/splittabledofn/SplitResult.java} | 22 ++++++++-----
.../org/apache/beam/sdk/transforms/WatchTest.java | 14 +++++---
.../sdk/transforms/reflect/DoFnInvokersTest.java | 3 +-
.../splittabledofn/ByteKeyRangeTrackerTest.java | 18 +++++-----
.../splittabledofn/OffsetRangeTrackerTest.java | 12 +++----
.../splittabledofn/SplitResultTest.java} | 15 +++++----
.../sdk/fn/splittabledofn/RestrictionTrackers.java | 5 +--
.../fn/splittabledofn/RestrictionTrackersTest.java | 5 +--
18 files changed, 112 insertions(+), 110 deletions(-)
copy sdks/java/{io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/Transaction.java => core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/SplitResult.java} (60%)
copy sdks/java/{io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryCoderProviderRegistrarTest.java => core/src/test/java/org/apache/beam/sdk/transforms/splittabledofn/SplitResultTest.java} (71%)