This is an automated email from the ASF dual-hosted git repository. ibzib pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
View the commit online: https://github.com/apache/beam/commit/50df5e83c03f59a81a864097d7dd4f0134eb49be The following commit(s) were added to refs/heads/master by this push: new 50df5e8 [BEAM-8795] fix Spark runner build new 62beb37 Merge pull request #10182 from ibzib/spark-build 50df5e8 is described below commit 50df5e83c03f59a81a864097d7dd4f0134eb49be Author: Kyle Weaver <[email protected]> AuthorDate: Wed Nov 20 14:44:57 2019 -0800 [BEAM-8795] fix Spark runner build --- .../translation/batch/functions/SparkSideInputReader.java | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/functions/SparkSideInputReader.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/functions/SparkSideInputReader.java index 5d49767..1099949 100644 --- a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/functions/SparkSideInputReader.java +++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/functions/SparkSideInputReader.java @@ -34,6 +34,7 @@ import org.apache.beam.runners.spark.structuredstreaming.translation.helpers.Sid import org.apache.beam.sdk.coders.Coder; import org.apache.beam.sdk.coders.KvCoder; import org.apache.beam.sdk.transforms.Materializations; +import org.apache.beam.sdk.transforms.Materializations.MultimapView; import org.apache.beam.sdk.transforms.ViewFn; import org.apache.beam.sdk.transforms.windowing.BoundedWindow; import org.apache.beam.sdk.util.WindowedValue; @@ -46,7 +47,17 @@ import org.apache.beam.sdk.values.WindowingStrategy; public class SparkSideInputReader implements SideInputReader { /** A {@link Materializations.MultimapView} which always returns an empty iterable. */ private static final Materializations.MultimapView EMPTY_MULTIMAP_VIEW = - o -> Collections.EMPTY_LIST; + new MultimapView() { + @Override + public Iterable get() { + return Collections.EMPTY_LIST; + } + + @Override + public Iterable get(@Nullable Object o) { + return Collections.EMPTY_LIST; + } + }; private final Map<TupleTag<?>, WindowingStrategy<?, ?>> sideInputs; private final SideInputBroadcast broadcastStateData;
