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 f5fd0127bd5327373b134e838849c702f10cf045
Author: Etienne Chauchot <echauc...@apache.org>
AuthorDate: Tue Jan 15 13:37:56 2019 +0100
Fix errorprone
---
.../structuredstreaming/translation/batch/ParDoTranslatorBatch.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 1ad1e3b..9cbde5a 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
@@ -184,7 +184,7 @@ class ParDoTranslatorBatch<InputT, OutputT>
context.putDatasetWildcard(output.getValue(), outputDataset);
}
- class SparkDoFnFilterFunction implements FilterFunction<Tuple2<TupleTag<?>,
WindowedValue<?>>> {
+ static class SparkDoFnFilterFunction implements
FilterFunction<Tuple2<TupleTag<?>, WindowedValue<?>>> {
private final TupleTag<?> key;
