Package | Description |
---|---|
org.apache.sysml.runtime.instructions.spark.utils | |
org.apache.sysml.runtime.matrix.data |
Modifier and Type | Method and Description |
---|---|
static Pair<MatrixIndexes,MatrixBlock> |
SparkUtils.fromIndexedMatrixBlockToPair(org.apache.sysml.runtime.matrix.mapred.IndexedMatrixValue in) |
static Pair<Long,FrameBlock> |
SparkUtils.toIndexedFrameBlock(scala.Tuple2<Long,FrameBlock> in) |
Modifier and Type | Method and Description |
---|---|
static List<Pair<MatrixIndexes,MatrixBlock>> |
SparkUtils.fromIndexedMatrixBlockToPair(List<org.apache.sysml.runtime.matrix.mapred.IndexedMatrixValue> in) |
static List<Pair<Long,Long>> |
SparkUtils.toIndexedLong(List<scala.Tuple2<Long,Long>> in) |
Modifier and Type | Method and Description |
---|---|
static org.apache.spark.api.java.JavaPairRDD<Long,FrameBlock> |
FrameRDDConverterUtils.dataFrameToBinaryBlock(org.apache.spark.api.java.JavaSparkContext sc,
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> df,
MatrixCharacteristics mc,
boolean containsID,
Pair<String[],org.apache.sysml.parser.Expression.ValueType[]> out) |
static scala.Tuple2<Long,FrameBlock> |
SparkUtils.fromIndexedFrameBlock(Pair<Long,FrameBlock> in) |
Modifier and Type | Method and Description |
---|---|
static List<scala.Tuple2<Long,FrameBlock>> |
SparkUtils.fromIndexedFrameBlock(List<Pair<Long,FrameBlock>> in) |
Modifier and Type | Method and Description |
---|---|
Pair<MatrixIndexes,MatrixBlock> |
TextCellToRowBlockConverter.next() |
Pair<MatrixIndexes,MatrixBlock> |
BinaryCellToRowBlockConverter.next() |
Pair<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> |
IdenticalConverter.next() |
Pair<MatrixIndexes,WeightedPair> |
AddDummyWeightConverter.next() |
Pair<K2,V2> |
Converter.next() |
Pair<MatrixIndexes,MatrixBlock> |
BinaryBlockToRowBlockConverter.next() |
Pair<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text> |
BinaryCellToTextConverter.next() |
Pair<org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.IntWritable> |
WeightedCellToSortInputConverter.next() |
Pair<MatrixIndexes,MatrixCell> |
TextToBinaryCellConverter.next() |
Pair<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text> |
BinaryBlockToTextCellConverter.next() |
Pair<MatrixIndexes,MatrixCell> |
BinaryBlockToBinaryCellConverter.next() |
Modifier and Type | Method and Description |
---|---|
static void |
OperationsOnMatrixValues.performShift(Pair<Long,FrameBlock> in,
org.apache.sysml.runtime.util.IndexRange ixrange,
int brlenLeft,
int clenLeft,
long rlen,
long clen,
ArrayList<Pair<Long,FrameBlock>> outlist) |
static void |
OperationsOnMatrixValues.performSlice(Pair<Long,FrameBlock> in,
org.apache.sysml.runtime.util.IndexRange ixrange,
int brlen,
int bclen,
ArrayList<Pair<Long,FrameBlock>> outlist)
This function will get slice of the input frame block overlapping in overall slice(Range), slice has requested for.
|
Modifier and Type | Method and Description |
---|---|
static void |
OperationsOnMatrixValues.performShift(Pair<Long,FrameBlock> in,
org.apache.sysml.runtime.util.IndexRange ixrange,
int brlenLeft,
int clenLeft,
long rlen,
long clen,
ArrayList<Pair<Long,FrameBlock>> outlist) |
static void |
OperationsOnMatrixValues.performSlice(Pair<Long,FrameBlock> in,
org.apache.sysml.runtime.util.IndexRange ixrange,
int brlen,
int bclen,
ArrayList<Pair<Long,FrameBlock>> outlist)
This function will get slice of the input frame block overlapping in overall slice(Range), slice has requested for.
|
void |
FrameBlock.slice(ArrayList<Pair<Long,FrameBlock>> outlist,
org.apache.sysml.runtime.util.IndexRange range,
int rowCut) |
Copyright © 2018 The Apache Software Foundation. All rights reserved.