This is an automated email from the ASF dual-hosted git repository.
jkff pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 282636275f3f91cc8a15aa08d8039bcb81d2f9d6
Merge: a67262f 6857cb9
Author: Eugene Kirpichov <ekirpic...@gmail.com>
AuthorDate: Tue Feb 6 10:07:11 2018 -0800
Merge pull request #4483: [BEAM-3499, BEAM-2607] Gives the runner access to
positions of SDF claimed blocks
[BEAM-3499, BEAM-2607] Gives the runner access to positions of SDF claimed
blocks
.../runners/apex/translation/ParDoTranslator.java | 2 +-
.../translation/operators/ApexParDoOperator.java | 2 +-
.../core/construction/PTransformMatchersTest.java | 2 +-
.../core/construction/ParDoTranslationTest.java | 4 +-
.../core/construction/SplittableParDoTest.java | 7 +-
.../beam/runners/core/InMemoryStateInternals.java | 77 ++++++++--
...TimeBoundedSplittableProcessElementInvoker.java | 100 +++++++++---
.../apache/beam/runners/core/SimpleDoFnRunner.java | 8 +-
.../core/SplittableParDoViaKeyedWorkItems.java | 4 +-
.../core/SplittableProcessElementInvoker.java | 2 +-
...BoundedSplittableProcessElementInvokerTest.java | 111 +++++++++++---
.../runners/core/SplittableParDoProcessFnTest.java | 34 +++--
.../direct/CopyOnAccessInMemoryStateInternals.java | 10 +-
.../SplittableProcessElementsEvaluatorFactory.java | 6 +-
.../flink/FlinkStreamingTransformTranslators.java | 2 +-
.../wrappers/streaming/SplittableDoFnOperator.java | 2 +-
runners/google-cloud-dataflow-java/pom.xml | 2 +-
.../org/apache/beam/sdk/coders/SnappyCoder.java | 65 ++++++++
.../org/apache/beam/sdk/transforms/DoFnTester.java | 2 +-
.../java/org/apache/beam/sdk/transforms/Watch.java | 167 ++++++++++++++-------
.../beam/sdk/transforms/reflect/DoFnInvoker.java | 6 +-
.../sdk/transforms/reflect/DoFnSignatures.java | 6 +-
.../splittabledofn/HasDefaultTracker.java | 2 +-
.../splittabledofn/OffsetRangeTracker.java | 12 +-
.../splittabledofn/RestrictionTracker.java | 76 +++++++++-
.../beam/sdk/transforms/SplittableDoFnTest.java | 6 +-
.../org/apache/beam/sdk/transforms/WatchTest.java | 126 ++++++----------
.../sdk/transforms/reflect/DoFnInvokersTest.java | 14 +-
.../reflect/DoFnSignaturesProcessElementTest.java | 2 +-
.../reflect/DoFnSignaturesSplittableDoFnTest.java | 11 +-
.../splittabledofn/OffsetRangeTrackerTest.java | 73 +++++----
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 6 +-
32 files changed, 654 insertions(+), 295 deletions(-)
--
To stop receiving notification emails like this one, please contact
j...@apache.org.
