Package com.gengoai.stream.spark

Class Summary

Class	Description
AccumulatorV2Wrapper<IN,OUT>	Wraps a LocalMAccumulator making it usable by Spark
SparkMAccumulator<IN,OUT>	Generic accumulator for distributed Spark streams.
SparkMCounterAccumulator<E>	Counter accumulator implementation for Spark streams
SparkMDoubleAccumulator	An implementation of a MDoubleAccumulator for spark streams
SparkMLongAccumulator	An implementation of a MLongAccumulator for spark streams
SparkMMapAccumulator<K,V>	An implementation of a MMapAccumulator for Spark streams
SparkMMultiCounterAccumulator<K1,K2>	An implementation of a MMultiCounterAccumulator for Spark streams
SparkMStatisticsAccumulator	An implementation of a MStatisticsAccumulator for Spark streams
SparkPairStream<T,U>	A MPairStream implementation backed by a JavaPairRDD.
SparkStream<T>	A MStream wrapper around a Spark RDD.
SparkStreamingContext	Represents a distributed streaming context using Sparks's rdd classes