Hierarchy For Package com.gengoai.stream.spark

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.spark.util.AccumulatorV2<IN,OUT> (implements scala.Serializable)
    • com.gengoai.stream.spark.AccumulatorV2Wrapper<IN,OUT> (implements java.io.Serializable)
  • com.gengoai.stream.spark.SparkMAccumulator<IN,OUT> (implements com.gengoai.stream.MAccumulator<IN,OUT>)
    • com.gengoai.stream.spark.SparkMCounterAccumulator<E> (implements com.gengoai.stream.MCounterAccumulator<T>)
    • com.gengoai.stream.spark.SparkMDoubleAccumulator (implements com.gengoai.stream.MDoubleAccumulator)
    • com.gengoai.stream.spark.SparkMLongAccumulator (implements com.gengoai.stream.MLongAccumulator)
    • com.gengoai.stream.spark.SparkMMapAccumulator<K,V> (implements com.gengoai.stream.MMapAccumulator<K,V>)
    • com.gengoai.stream.spark.SparkMMultiCounterAccumulator<K1,K2> (implements com.gengoai.stream.MMultiCounterAccumulator<K1,K2>)
    • com.gengoai.stream.spark.SparkMStatisticsAccumulator (implements com.gengoai.stream.MStatisticsAccumulator)
  • com.gengoai.stream.spark.SparkPairStream<T,U> (implements com.gengoai.stream.MPairStream<T,U>, java.io.Serializable)
  • com.gengoai.stream.spark.SparkStream<T> (implements com.gengoai.stream.MStream<T>, java.io.Serializable)
  • com.gengoai.stream.StreamingContext (implements java.lang.AutoCloseable, java.io.Serializable)
    • com.gengoai.stream.spark.SparkStreamingContext