org.deeplearning4j.streaming.pipeline.spark

Class StreamingContextUtils

java.lang.Object

org.deeplearning4j.streaming.pipeline.spark.StreamingContextUtils

public class StreamingContextUtils
extends java.lang.Object

In order to handle changes between Spark 1.x and 2.x

Constructor Summary

Constructors

Constructor and Description
StreamingContextUtils()

Method Summary

Modifier and Type	Method and Description
static <K> void	foreach(org.apache.spark.streaming.api.java.JavaDStream<K> stream, org.apache.spark.api.java.function.Function<org.apache.spark.api.java.JavaRDD<K>,java.lang.Void> func)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamingContextUtils

public StreamingContextUtils()

Method Detail

foreach

public static <K> void foreach(org.apache.spark.streaming.api.java.JavaDStream<K> stream,
                               org.apache.spark.api.java.function.Function<org.apache.spark.api.java.JavaRDD<K>,java.lang.Void> func)