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 <aromanenko....@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) {