[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(-) ----------------------------------------------------------------------