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.