Modifier and Type | Method and Description |
---|---|
static MatrixBlock |
SparkExecutionContext.toMatrixBlock(org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixCell> rdd,
int rlen,
int clen,
long nnz)
Utility method for creating a single matrix block out of a binary cell RDD.
|
Modifier and Type | Field and Description |
---|---|
MatrixCell |
PairWritableCell.cell |
Modifier and Type | Method and Description |
---|---|
MatrixCell |
ParameterizedBuiltinSPInstruction.CreateMatrixCell.call(WeightedCell kv) |
Modifier and Type | Method and Description |
---|---|
void |
ParameterizedBuiltinSPInstruction.setOutputCharacteristicsForGroupedAgg(DataCharacteristics mc1,
DataCharacteristics mcOut,
org.apache.spark.api.java.JavaPairRDD<MatrixIndexes,MatrixCell> out) |
Modifier and Type | Method and Description |
---|---|
scala.Tuple2<MatrixIndexes,MatrixCell> |
CopyBinaryCellFunction.call(scala.Tuple2<MatrixIndexes,MatrixCell> arg0) |
Modifier and Type | Method and Description |
---|---|
scala.Tuple2<MatrixIndexes,MatrixCell> |
CopyBinaryCellFunction.call(scala.Tuple2<MatrixIndexes,MatrixCell> arg0) |
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,
DataCharacteristics 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 DataCharacteristics |
SparkUtils.computeDataCharacteristics(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 |
WeightedCell |
class |
WeightedPair |
Modifier and Type | Method and Description |
---|---|
Pair<MatrixIndexes,MatrixCell> |
TextToBinaryCellConverter.next() |
Modifier and Type | Method and Description |
---|---|
int |
MatrixCell.compareTo(MatrixCell o) |
Constructor and Description |
---|
MatrixCell(MatrixCell that) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.