| Package | Description | 
|---|---|
| org.apache.sysml.runtime.instructions.spark | |
| org.apache.sysml.runtime.instructions.spark.utils | |
| org.apache.sysml.runtime.matrix.data | 
| Modifier and Type | Method and Description | 
|---|---|
MatrixCell | 
ParameterizedBuiltinSPInstruction.CreateMatrixCell.call(WeightedCell kv)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ParameterizedBuiltinSPInstruction.setOutputCharacteristicsForGroupedAgg(MatrixCharacteristics mc1,
                                     MatrixCharacteristics mcOut,
                                     org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixCell> out)  | 
| Modifier and Type | Method and Description | 
|---|---|
static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixCell> | 
SparkUtils.cacheBinaryCellRDD(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixCell> input)  | 
| Modifier and Type | Method and Description | 
|---|---|
static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixBlock> | 
RDDConverterUtils.binaryCellToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc,
                       org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixCell> input,
                       MatrixCharacteristics mcOut,
                       boolean outputEmptyBlocks)  | 
static org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixCell> | 
SparkUtils.cacheBinaryCellRDD(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixCell> input)  | 
static MatrixCharacteristics | 
SparkUtils.computeMatrixCharacteristics(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixCell> input)
Utility to compute dimensions and non-zeros in a given RDD of binary cells. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
MatrixPackedCell  | 
class  | 
WeightedCell  | 
class  | 
WeightedPair  | 
| Modifier and Type | Method and Description | 
|---|---|
Pair<MatrixIndexes,MatrixCell> | 
TextToBinaryCellConverter.next()  | 
Pair<MatrixIndexes,MatrixCell> | 
BinaryBlockToBinaryCellConverter.next()  | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
MatrixCell.compareTo(MatrixCell o)  | 
void | 
BinaryCellToTextConverter.convert(MatrixIndexes k1,
       MatrixCell v1)  | 
void | 
BinaryCellToRowBlockConverter.convert(MatrixIndexes k1,
       MatrixCell v1)  | 
| Constructor and Description | 
|---|
MatrixCell(MatrixCell that)  | 
TaggedMatrixCell(MatrixCell b,
                byte t)  | 
Copyright © 2017 The Apache Software Foundation. All rights reserved.