Uses of Class
com.gengoai.stream.StreamingContext
-
Packages that use StreamingContext Package Description com.gengoai.stream A unified stream interface that can work across Java and Spark streams.com.gengoai.stream.local com.gengoai.stream.spark -
-
Uses of StreamingContext in com.gengoai.stream
Methods in com.gengoai.stream that return StreamingContext Modifier and Type Method Description static StreamingContext
StreamingContext. get()
Gets the public streaming context as defined.static StreamingContext
StreamingContext. get(boolean distributed)
Gets a streaming context.StreamingContext
MDoubleStream. getContext()
Gets the context used to create the streamStreamingContext
MPairStream. getContext()
Gets the context used to create the streamStreamingContext
MStream. getContext()
Gets the context used to create the stream -
Uses of StreamingContext in com.gengoai.stream.local
Subclasses of StreamingContext in com.gengoai.stream.local Modifier and Type Class Description class
LocalStreamingContext
Represents a local streaming context using Java's built-in streamsMethods in com.gengoai.stream.local that return StreamingContext Modifier and Type Method Description StreamingContext
AbstractLocalMPairStream. getContext()
StreamingContext
LocalMDoubleStream. getContext()
-
Uses of StreamingContext in com.gengoai.stream.spark
Subclasses of StreamingContext in com.gengoai.stream.spark Modifier and Type Class Description class
SparkStreamingContext
Represents a distributed streaming context using Sparks's rdd classesMethods in com.gengoai.stream.spark that return StreamingContext Modifier and Type Method Description StreamingContext
SparkPairStream. getContext()
-