beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [beam] branch master updated (ffea03a -> ab32135)
Date Tue, 02 Apr 2019 15:36:50 GMT
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


Mime
View raw message