| BlockPartitioner |
Default 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 |
|
| SerLongWritable |
Wrapper for LongWritable in order to make it serializable as required for
shuffle in spark instructions.
|
| SerText |
Wrapper for Text in order to make it serializable as required for
shuffle in spark instructions.
|