beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From echauc...@apache.org
Subject [beam] 34/45: Fix javadoc of AggregatorCombiner
Date Tue, 09 Jul 2019 13:18:51 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 721b1d0ff63222567b8c16484bbf57c693385ffa
Author: Etienne Chauchot <echauchot@apache.org>
AuthorDate: Thu Jul 4 11:27:28 2019 +0200

    Fix javadoc of AggregatorCombiner
---
 .../structuredstreaming/translation/batch/AggregatorCombiner.java      | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/AggregatorCombiner.java
b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/AggregatorCombiner.java
index c61d937..138e5c2 100644
--- a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/AggregatorCombiner.java
+++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/AggregatorCombiner.java
@@ -41,8 +41,7 @@ import org.apache.spark.sql.expressions.Aggregator;
 import org.joda.time.Instant;
 import scala.Tuple2;
 
-/** An {@link Aggregator} for the Spark Batch Runner. It does not use ReduceFnRunner
- * for windowMerging, because reduceFnRunner is based on state which requires a keyed collection.
+/** An {@link Aggregator} for the Spark Batch Runner.
  * The accumulator is a {@code Iterable<WindowedValue<AccumT>> because an {@code
InputT} can be in multiple windows. So, when accumulating {@code InputT} values, we create
one accumulator per input window.
  * */
 


Mime
View raw message