beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tg...@apache.org
Subject [1/4] beam git commit: This closes #2512
Date Fri, 14 Apr 2017 21:41:09 GMT
Repository: beam
Updated Branches:
  refs/heads/master 89ff0b145 -> f30d5b9e9


This closes #2512


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f30d5b9e
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f30d5b9e
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f30d5b9e

Branch: refs/heads/master
Commit: f30d5b9e9db80e35c9fae4c05d2a76655922db1c
Parents: 89ff0b1 113471d
Author: Thomas Groh <tgroh@google.com>
Authored: Fri Apr 14 14:40:57 2017 -0700
Committer: Thomas Groh <tgroh@google.com>
Committed: Fri Apr 14 14:40:57 2017 -0700

----------------------------------------------------------------------
 .../apex/translation/ParDoTranslator.java       |   6 +-
 .../operators/ApexGroupByKeyOperator.java       |  19 +-
 .../operators/ApexParDoOperator.java            |  48 +--
 .../apex/translation/utils/NoOpStepContext.java |   2 +-
 .../apex/translation/ParDoTranslatorTest.java   |  18 +-
 .../beam/runners/core/BaseExecutionContext.java |  13 +-
 .../apache/beam/runners/core/DoFnAdapters.java  |  16 +-
 .../apache/beam/runners/core/DoFnRunners.java   |   8 +-
 .../beam/runners/core/ExecutionContext.java     |  13 +-
 .../GroupAlsoByWindowViaWindowSetNewDoFn.java   |   6 +-
 .../org/apache/beam/runners/core/OldDoFn.java   |  38 +--
 ...eBoundedSplittableProcessElementInvoker.java |   8 +-
 .../beam/runners/core/OutputWindowedValue.java  |  10 +-
 .../beam/runners/core/SimpleDoFnRunner.java     |  54 ++--
 .../beam/runners/core/SimpleOldDoFnRunner.java  |  63 ++--
 .../beam/runners/core/SplittableParDo.java      |  21 +-
 .../beam/runners/core/WindowingInternals.java   |   8 +-
 .../core/WindowingInternalsAdapters.java        |   8 +-
 .../core/GroupAlsoByWindowsProperties.java      |  10 +-
 .../apache/beam/runners/core/NoOpOldDoFn.java   |   4 +-
 .../apache/beam/runners/core/OldDoFnTest.java   |   4 +-
 ...ndedSplittableProcessElementInvokerTest.java |   6 +-
 .../beam/runners/core/ReduceFnTester.java       |   8 +-
 .../runners/core/SimpleOldDoFnRunnerTest.java   |   4 +-
 .../beam/runners/core/SplittableParDoTest.java  |   8 +-
 .../GroupAlsoByWindowEvaluatorFactory.java      |   8 +-
 .../beam/runners/direct/ParDoEvaluator.java     |   4 +-
 .../runners/direct/ParDoEvaluatorFactory.java   |  10 +-
 .../direct/ParDoMultiOverrideFactory.java       |   2 +-
 ...littableProcessElementsEvaluatorFactory.java |   8 +-
 .../direct/StatefulParDoEvaluatorFactory.java   |   2 +-
 .../beam/runners/direct/ParDoEvaluatorTest.java |   6 +-
 .../FlinkStreamingTransformTranslators.java     |  20 +-
 .../functions/FlinkDoFnFunction.java            |   4 +-
 .../functions/FlinkNoOpStepContext.java         |   2 +-
 .../functions/FlinkStatefulDoFnFunction.java    |   4 +-
 .../wrappers/streaming/DoFnOperator.java        |  14 +-
 .../streaming/SplittableDoFnOperator.java       |  10 +-
 .../wrappers/streaming/WindowDoFnOperator.java  |   4 +-
 .../flink/streaming/DoFnOperatorTest.java       |  34 +--
 .../dataflow/BatchStatefulParDoOverrides.java   |   2 +-
 .../runners/dataflow/BatchViewOverrides.java    |   6 +-
 .../dataflow/BatchViewOverridesTest.java        |   4 +-
 .../SparkGroupAlsoByWindowViaWindowSet.java     |  10 +-
 .../spark/translation/MultiDoFnFunction.java    |   4 +-
 ...SparkGroupAlsoByWindowViaOutputBufferFn.java |   8 +-
 .../spark/translation/SparkProcessContext.java  |   2 +-
 .../streaming/StreamingTransformTranslator.java |   2 +-
 .../org/apache/beam/sdk/transforms/Combine.java |   2 +-
 .../org/apache/beam/sdk/transforms/DoFn.java    |  14 +-
 .../apache/beam/sdk/transforms/DoFnTester.java  |  41 ++-
 .../org/apache/beam/sdk/transforms/ParDo.java   |  77 +++--
 .../apache/beam/sdk/transforms/Partition.java   |   2 +-
 .../beam/sdk/values/PCollectionTuple.java       |   3 +-
 .../org/apache/beam/sdk/values/TupleTag.java    |  26 +-
 .../apache/beam/sdk/values/TupleTagList.java    |   2 +-
 .../org/apache/beam/sdk/values/TypedPValue.java |   4 +-
 .../apache/beam/sdk/metrics/MetricsTest.java    |   2 +-
 .../apache/beam/sdk/transforms/ParDoTest.java   | 293 ++++++++++---------
 .../beam/sdk/transforms/SplittableDoFnTest.java |  21 +-
 .../beam/sdk/values/PCollectionTupleTest.java   |   8 +-
 .../apache/beam/sdk/values/TypedPValueTest.java |  46 +--
 .../beam/fn/harness/fake/FakeStepContext.java   |   2 +-
 .../control/ProcessBundleHandlerTest.java       |  30 +-
 .../sdk/io/gcp/bigquery/WritePartition.java     |   6 +-
 .../sdk/io/gcp/bigquery/BigQueryIOTest.java     |   4 +-
 66 files changed, 578 insertions(+), 578 deletions(-)
----------------------------------------------------------------------



Mime
View raw message