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) |
Iterator<scala.Tuple2<MatrixIndexes,MatrixBlock>> |
RDDConverterUtils.BinaryCellToBinaryBlockFunction.call(Iterator<scala.Tuple2<MatrixIndexes,MatrixCell>> arg0) |
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 |
BinaryCellToRowBlockConverter.convert(MatrixIndexes k1,
MatrixCell v1) |
void |
BinaryCellToTextConverter.convert(MatrixIndexes k1,
MatrixCell v1) |
Constructor and Description |
---|
MatrixCell(MatrixCell that) |
TaggedMatrixCell(MatrixCell b,
byte t) |
Copyright © 2018 The Apache Software Foundation. All rights reserved.