beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From echauc...@apache.org
Subject [beam] 10/13: add comment in combine globally test
Date Fri, 05 Jul 2019 13:53:20 GMT
This is an automated email from the ASF dual-hosted git repository.

echauchot pushed a commit to branch spark-runner_structured-streaming
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 0347a077c67c287ed899ed8c63cd351f73ba0f95
Author: Etienne Chauchot <echauchot@apache.org>
AuthorDate: Thu Jul 4 15:04:59 2019 +0200

    add comment in combine globally test
---
 .../runners/spark/structuredstreaming/translation/batch/CombineTest.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/runners/spark/src/test/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/CombineTest.java
b/runners/spark/src/test/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/CombineTest.java
index cdce691..b3a2915 100644
--- a/runners/spark/src/test/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/CombineTest.java
+++ b/runners/spark/src/test/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/CombineTest.java
@@ -51,6 +51,7 @@ public class CombineTest implements Serializable {
     PCollection<Integer> input =
         p.apply(Create.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)).apply(Sum.integersGlobally());
     PAssert.that(input).containsInAnyOrder(55);
+    // uses combine per key
     p.run();
   }
 


Mime
View raw message