Uses of Class
com.gengoai.stream.spark.SparkStream

Packages that use SparkStream

Package	Description
com.gengoai.stream	A unified stream interface that can work across Java and Spark streams.
com.gengoai.stream.spark

Uses of SparkStream in com.gengoai.stream

Methods in com.gengoai.stream that return SparkStream

Modifier and Type	Method	Description
default SparkStream<T>	MStream.toDistributedStream()	To distributed stream spark stream.

Uses of SparkStream in com.gengoai.stream.spark

Methods in com.gengoai.stream.spark that return SparkStream

Modifier and Type	Method	Description
SparkStream<T>	SparkStream.cache()
SparkStream<T>	SparkStream.distinct()
<T> SparkStream<T>	SparkStreamingContext.empty()
SparkStream<T>	SparkStream.filter(SerializablePredicate<? super T> predicate)
<R> SparkStream<R>	SparkStream.flatMap(SerializableFunction<? super T,Stream<? extends R>> mapper)
SparkStream<T>	SparkStream.limit(long number)
<R> SparkStream<R>	SparkStream.map(SerializableFunction<? super T,? extends R> function)
<R> SparkStream<R>	SparkStream.mapPartitions(SerializableFunction<Iterator<? super T>,Stream<R>> function)	Maps the objects in the stream by block using the given function
SparkStream<T>	SparkStream.parallel()
SparkStream<Integer>	SparkStreamingContext.range(int startInclusive, int endExclusive)
SparkStream<T>	SparkStream.repartition(int numPartitions)
SparkStream<T>	SparkStream.sample(boolean withReplacement, int number)
SparkStream<T>	SparkStream.shuffle()
SparkStream<T>	SparkStream.shuffle(Random random)
SparkStream<T>	SparkStream.skip(long n)
<T> SparkStream<T>	SparkStreamingContext.stream(Iterable<? extends T> iterable)
<T> SparkStream<T>	SparkStreamingContext.stream(Stream<T> stream)
SparkStream<String>	SparkStreamingContext.textFile(Resource location)
SparkStream<String>	SparkStreamingContext.textFile(String location)
SparkStream<T>	SparkStream.toDistributedStream()
SparkStream<T>	SparkStream.union(MStream<T> other)

Methods in com.gengoai.stream.spark with parameters of type SparkStream

Modifier and Type	Method	Description
static SparkStreamingContext	SparkStreamingContext.contextOf(SparkStream<?> stream)	Gets the streaming context of a given spark stream