You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/04/25 17:30:34 UTC
[39/50] [abbrv] beam git commit: [BEAM-1991] Sum.SumDoubleFn =>
Sum.ofDoubles
[BEAM-1991] Sum.SumDoubleFn => Sum.ofDoubles
This is left over from commit 78a360eac35507d9a558fc6117bb56b67b8a884e
- [x] Make sure the PR title is formatted like:
`[BEAM-<Jira issue #>] Description of pull request`
- [x] Make sure tests pass via `mvn clean verify`. (Even better, enable
Travis-CI on your fork and ensure the whole test matrix passes).
- [x] Replace `<Jira issue #>` in the title with the actual Jira issue
number, if there is one.
- [ ] If this contribution is large, please file an Apache
[Individual Contributor License Agreement](https://www.apache.org/licenses/icla.pdf).
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7c858a8a
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7c858a8a
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7c858a8a
Branch: refs/heads/jstorm-runner
Commit: 7c858a8aa7aa3ff27e9d38f9ff952285227d199e
Parents: 36e4355
Author: wtanaka.com <wt...@yahoo.com>
Authored: Mon Apr 17 16:45:45 2017 -1000
Committer: Dan Halperin <dh...@google.com>
Committed: Mon Apr 17 21:02:33 2017 -0700
----------------------------------------------------------------------
.../core/src/main/java/org/apache/beam/sdk/transforms/Combine.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/7c858a8a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Combine.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Combine.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Combine.java
index 58d65d0..1de6d8c 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Combine.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Combine.java
@@ -1775,7 +1775,7 @@ public class Combine {
* PCollection<KV<String, Double>> salesRecords = ...;
* PCollection<KV<String, Double>> totalSalesPerPerson =
* salesRecords.apply(Combine.<String, Double, Double>perKey(
- * new Sum.SumDoubleFn()));
+ * Sum.ofDoubles()));
* } </pre>
*
* <p>Each output element is in the window by which its corresponding input