[beam] branch spark-runner_structured-streaming updated: Rename pruneOutput() to pruneOutputFilteredByTag()

[ar...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/spark-runner_structured-streaming by this push:
     new c077daa  Rename pruneOutput() to pruneOutputFilteredByTag()
c077daa is described below

commit c077daa6bd7b91c86a6c2de2e875cb9a1b9d1279
Author: Alexey Romanenko <ar...@gmail.com>
AuthorDate: Fri Jan 25 17:31:44 2019 +0100

    Rename pruneOutput() to pruneOutputFilteredByTag()
---
 .../structuredstreaming/translation/batch/ParDoTranslatorBatch.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ParDoTranslatorBatch.java b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ParDoTranslatorBatch.java
index 93f9da0..a984615 100644
--- a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ParDoTranslatorBatch.java
+++ b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ParDoTranslatorBatch.java
@@ -147,7 +147,7 @@ class ParDoTranslatorBatch<InputT, OutputT>
         inputDataSet.mapPartitions(doFnWrapper, EncoderHelpers.tuple2Encoder());
 
     for (Map.Entry<TupleTag<?>, PValue> output : outputs.entrySet()) {
-      pruneOutput(context, allOutputsDataset, output);
+      pruneOutputFilteredByTag(context, allOutputsDataset, output);
     }
   }
 
@@ -182,7 +182,7 @@ class ParDoTranslatorBatch<InputT, OutputT>
     return doFn;
   }
 
-  private <T> void pruneOutput(
+  private void pruneOutputFilteredByTag(
       TranslationContext context,
       Dataset<Tuple2<TupleTag<?>, WindowedValue<?>>> tmpDataset,
       Map.Entry<TupleTag<?>, PValue> output) {