Uses of Package
com.gengoai.stream

Packages that use com.gengoai.stream

Package	Description
com.gengoai.io	Classes for reading and writing to various different sources, e.g.
com.gengoai.io.resource	A mix between Java's FileSystem and Spring's Resource
com.gengoai.math
com.gengoai.stream	A unified stream interface that can work across Java and Spark streams.
com.gengoai.stream.local
com.gengoai.stream.spark

Classes in com.gengoai.stream used by com.gengoai.io

Class	Description
MStream	A facade for stream classes, such as Java's Stream and Spark's RDD objects.

Classes in com.gengoai.stream used by com.gengoai.io.resource

Class	Description
MStream	A facade for stream classes, such as Java's Stream and Spark's RDD objects.

Classes in com.gengoai.stream used by com.gengoai.math

Class	Description
MStream	A facade for stream classes, such as Java's Stream and Spark's RDD objects.

Classes in com.gengoai.stream used by com.gengoai.stream

Class	Description
MAccumulator	Base interface for accumulators that can work across local and distributed streams.
MCounterAccumulator	Accumulator for Counters
MDoubleAccumulator	Accumulator for doubles
MDoubleStream	A facade for double stream classes, such as Java's DoubleStream and Spark's DoubleRDD objects.
MLongAccumulator	Accumulator for longs
MMapAccumulator	Accumulator for Maps
MMultiCounterAccumulator	An accumulator for MultiCounters
MPairStream	A facade for stream classes which contain key-value pairs.
MStatisticsAccumulator	Accumulator for calculating descriptive statistics
MStream	A facade for stream classes, such as Java's Stream and Spark's RDD objects.
StorageLevel
StreamingContext	Provides methods for creating MStreams and MAccumulators within a given context, i.e.

Classes in com.gengoai.stream used by com.gengoai.stream.local

Class	Description
MAccumulator	Base interface for accumulators that can work across local and distributed streams.
MCounterAccumulator	Accumulator for Counters
MDoubleAccumulator	Accumulator for doubles
MDoubleStream	A facade for double stream classes, such as Java's DoubleStream and Spark's DoubleRDD objects.
MLongAccumulator	Accumulator for longs
MMapAccumulator	Accumulator for Maps
MMultiCounterAccumulator	An accumulator for MultiCounters
MPairStream	A facade for stream classes which contain key-value pairs.
MStatisticsAccumulator	Accumulator for calculating descriptive statistics
MStream	A facade for stream classes, such as Java's Stream and Spark's RDD objects.
StorageLevel
StreamingContext	Provides methods for creating MStreams and MAccumulators within a given context, i.e.

Classes in com.gengoai.stream used by com.gengoai.stream.spark

Class	Description
MAccumulator	Base interface for accumulators that can work across local and distributed streams.
MCounterAccumulator	Accumulator for Counters
MDoubleAccumulator	Accumulator for doubles
MDoubleStream	A facade for double stream classes, such as Java's DoubleStream and Spark's DoubleRDD objects.
MLongAccumulator	Accumulator for longs
MMapAccumulator	Accumulator for Maps
MMultiCounterAccumulator	An accumulator for MultiCounters
MPairStream	A facade for stream classes which contain key-value pairs.
MStatisticsAccumulator	Accumulator for calculating descriptive statistics
MStream	A facade for stream classes, such as Java's Stream and Spark's RDD objects.
StorageLevel
StreamingContext	Provides methods for creating MStreams and MAccumulators within a given context, i.e.