Hierarchy For Package com.gengoai.stream.local

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • com.gengoai.stream.local.AbstractLocalMPairStream<K,V> (implements com.gengoai.stream.MPairStream<T,U>, java.io.Serializable)
    • com.gengoai.stream.local.LocalDefaultMPairStream<K,V>
  • com.gengoai.stream.local.LocalInMemoryMStream<T>
  • com.gengoai.stream.local.LocalMAccumulator<IN,OUT> (implements com.gengoai.Copyable<E>, com.gengoai.stream.MAccumulator<IN,OUT>)
    • com.gengoai.stream.local.LocalMCounterAccumulator<IN> (implements com.gengoai.stream.MCounterAccumulator<T>)
    • com.gengoai.stream.local.LocalMDoubleAccumulator (implements com.gengoai.stream.MDoubleAccumulator)
    • com.gengoai.stream.local.LocalMListAccumulator<E>
    • com.gengoai.stream.local.LocalMLongAccumulator (implements com.gengoai.stream.MLongAccumulator)
    • com.gengoai.stream.local.LocalMMapAccumulator<K,V> (implements com.gengoai.stream.MMapAccumulator<K,V>)
    • com.gengoai.stream.local.LocalMMultiCounterAccumulator<K1,K2> (implements com.gengoai.stream.MMultiCounterAccumulator<K1,K2>)
    • com.gengoai.stream.local.LocalMSetAccumulator<E>
    • com.gengoai.stream.local.LocalMStatisticsAccumulator (implements com.gengoai.stream.MStatisticsAccumulator)
  • com.gengoai.stream.local.LocalMDoubleStream (implements com.gengoai.stream.MDoubleStream, java.io.Serializable)
  • com.gengoai.stream.local.LocalReusableMStream<T>
  • com.gengoai.stream.StreamingContext (implements java.lang.AutoCloseable, java.io.Serializable)
    • com.gengoai.stream.local.LocalStreamingContext