| 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.