Uses of Class
com.gengoai.stream.spark.SparkStreamingContext
-
Packages that use SparkStreamingContext Package Description com.gengoai.stream A unified stream interface that can work across Java and Spark streams.com.gengoai.stream.spark -
-
Uses of SparkStreamingContext in com.gengoai.stream
Methods in com.gengoai.stream that return SparkStreamingContext Modifier and Type Method Description static SparkStreamingContext
StreamingContext. distributed()
Gets the distributed streaming context. -
Uses of SparkStreamingContext in com.gengoai.stream.spark
Fields in com.gengoai.stream.spark declared as SparkStreamingContext Modifier and Type Field Description static SparkStreamingContext
SparkStreamingContext. INSTANCE
The singleton instance of the contextMethods in com.gengoai.stream.spark that return SparkStreamingContext Modifier and Type Method Description static SparkStreamingContext
SparkStreamingContext. contextOf(com.gengoai.stream.spark.SparkDoubleStream stream)
Gets the streaming context of a given spark streamstatic SparkStreamingContext
SparkStreamingContext. contextOf(SparkPairStream<?,?> stream)
Gets the streaming context of a given spark streamstatic SparkStreamingContext
SparkStreamingContext. contextOf(SparkStream<?> stream)
Gets the streaming context of a given spark streamSparkStreamingContext
SparkStream. getContext()
-