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 2017/01/03 22:36:42 UTC
[7/7] beam git commit: [BEAM-1223] Introduced Sum, Min,
Max#ofLongs()/ofDoubles()/ofIntegers()
[BEAM-1223] Introduced Sum,Min,Max#ofLongs()/ofDoubles()/ofIntegers()
This closes #1723
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d86db15b
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d86db15b
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d86db15b
Branch: refs/heads/master
Commit: d86db15ba22cbd99093327dc4962e06fa2d5db43
Parents: e794f14 3e16e32
Author: Luke Cwik <lc...@google.com>
Authored: Tue Jan 3 14:36:24 2017 -0800
Committer: Luke Cwik <lc...@google.com>
Committed: Tue Jan 3 14:36:24 2017 -0800
----------------------------------------------------------------------
.../beam/examples/DebuggingWordCount.java | 4 +-
.../org/apache/beam/examples/WordCount.java | 2 +-
.../cookbook/CombinePerKeyExamples.java | 2 +-
.../beam/examples/complete/game/GameStats.java | 2 +-
.../beam/examples/complete/game/UserScore.java | 2 +-
.../runners/apex/examples/WordCountTest.java | 2 +-
.../utils/ApexStateInternalsTest.java | 2 +-
.../core/GroupAlsoByWindowViaWindowSetDoFn.java | 4 +-
.../runners/core/GroupAlsoByWindowsDoFn.java | 4 +-
.../apache/beam/runners/core/NonEmptyPanes.java | 2 +-
.../AfterDelayFromFirstElementStateMachine.java | 2 +-
.../core/triggers/AfterPaneStateMachine.java | 2 +-
.../core/LateDataDroppingDoFnRunnerTest.java | 2 +-
.../beam/runners/core/ReduceFnRunnerTest.java | 12 +--
.../beam/runners/core/ReduceFnTester.java | 2 +-
.../GroupAlsoByWindowEvaluatorFactory.java | 4 +-
.../runners/direct/AggregatorContainerTest.java | 16 ++--
.../CopyOnAccessInMemoryStateInternalsTest.java | 4 +-
.../runners/direct/EvaluationContextTest.java | 6 +-
.../beam/runners/flink/examples/WordCount.java | 2 +-
.../flink/examples/streaming/AutoComplete.java | 2 +-
.../KafkaWindowedWordCountExample.java | 2 +-
.../examples/streaming/WindowedWordCount.java | 2 +-
.../streaming/FlinkStateInternalsTest.java | 2 +-
.../dataflow/DataflowPipelineJobTest.java | 8 +-
.../spark/aggregators/NamedAggregators.java | 4 +-
.../beam/runners/spark/examples/WordCount.java | 2 +-
.../translation/SparkGroupAlsoByWindowFn.java | 2 +-
.../spark/translation/SparkRuntimeContext.java | 63 +++++----------
.../ResumeFromCheckpointStreamingTest.java | 2 +-
.../streaming/utils/PAssertStreaming.java | 4 +-
.../apache/beam/sdk/io/PubsubUnboundedSink.java | 8 +-
.../beam/sdk/io/PubsubUnboundedSource.java | 5 +-
.../org/apache/beam/sdk/testing/PAssert.java | 12 +--
.../org/apache/beam/sdk/transforms/Max.java | 85 +++++++++++++++-----
.../org/apache/beam/sdk/transforms/Mean.java | 21 ++++-
.../org/apache/beam/sdk/transforms/Min.java | 83 ++++++++++++++-----
.../org/apache/beam/sdk/transforms/Sum.java | 44 ++++++++--
.../windowing/AfterDelayFromFirstElement.java | 2 +-
.../sdk/transforms/windowing/AfterPane.java | 2 +-
.../sdk/AggregatorPipelineExtractorTest.java | 16 ++--
.../beam/sdk/transforms/CombineFnsTest.java | 20 +++--
.../apache/beam/sdk/transforms/DoFnTest.java | 15 ++--
.../beam/sdk/transforms/DoFnTesterTest.java | 6 +-
.../org/apache/beam/sdk/transforms/MaxTest.java | 6 +-
.../apache/beam/sdk/transforms/MeanTest.java | 2 +-
.../org/apache/beam/sdk/transforms/MinTest.java | 6 +-
.../beam/sdk/transforms/OldDoFnContextTest.java | 2 +-
.../apache/beam/sdk/transforms/OldDoFnTest.java | 11 ++-
.../beam/sdk/transforms/SimpleStatsFnsTest.java | 36 ++++-----
.../org/apache/beam/sdk/transforms/SumTest.java | 12 +--
.../apache/beam/sdk/transforms/ViewTest.java | 2 +-
.../apache/beam/sdk/util/CombineFnUtilTest.java | 8 +-
.../util/state/InMemoryStateInternalsTest.java | 2 +-
.../beam/sdk/util/state/StateTagTest.java | 11 ++-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 2 +-
56 files changed, 341 insertions(+), 249 deletions(-)
----------------------------------------------------------------------