Class Summary Class Description BlockPartitionerDefault partitioner used for all binary block rdd operations in order to enable sufficient local aggregation independent of the aggregation direction (row/col-wise). BroadcastObject<T extends CacheBlock<?>> CorrMatrixBlock DatasetObject FrameReblockBuffer IndexedMatrixValue LazyIterableIterator<T>This class is a generic base class for lazy, single pass iterator classes in order to simplify the implementation of lazy iterators for mapPartitions use cases. LineageObject PartitionedBlock<T extends CacheBlock>This class is for partitioned matrix/frame blocks, to be used as broadcasts. PartitionedBroadcast<T extends CacheBlock>This class is a wrapper around an array of broadcasts of partitioned matrix/frame blocks, which is required due to 2GB limitations of Spark's broadcast handling. RDDObject ReblockBuffer RowMatrixBlock SerLongWritableWrapper for LongWritable in order to make it serializable as required for shuffle in spark instructions. SerTextWrapper for Text in order to make it serializable as required for shuffle in spark instructions.