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

Packages that use SparkPairStream

Package	Description
com.gengoai.stream.spark

Uses of SparkPairStream in com.gengoai.stream.spark

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

Modifier and Type	Method	Description
<R,V> SparkPairStream<R,V>	SparkPairStream.flatMapToPair(SerializableBiFunction<? super T,? super U,Stream<Map.Entry<? extends R,? extends V>>> function)
<R,U> SparkPairStream<R,U>	SparkStream.flatMapToPair(SerializableFunction<? super T,Stream<? extends Map.Entry<? extends R,? extends U>>> function)
<U> SparkPairStream<U,Iterable<T>>	SparkStream.groupBy(SerializableFunction<? super T,? extends U> function)
<R,U> SparkPairStream<R,U>	SparkStream.mapToPair(SerializableFunction<? super T,? extends Map.Entry<? extends R,? extends U>> function)
<K,V> SparkPairStream<K,V>	SparkStreamingContext.pairStream(Collection<Map.Entry<? extends K,? extends V>> tuples)
<K,V> SparkPairStream<K,V>	SparkStreamingContext.pairStream(Map<? extends K,? extends V> map)
<U> SparkPairStream<T,U>	SparkStream.zip(MStream<U> other)
SparkPairStream<T,Long>	SparkStream.zipWithIndex()

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

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