Modifier and Type | Method and Description |
---|---|
Pair<Hop[],CNodeTpl> |
TemplateMultiAgg.constructCplan(Hop hop,
CPlanMemoTable memo,
boolean compileLiterals) |
abstract Pair<Hop[],CNodeTpl> |
TemplateBase.constructCplan(Hop hop,
CPlanMemoTable memo,
boolean compileLiterals)
Constructs a single cplan rooted at the given hop, according
to the plan given in the memo structure for this particular
hop and its recursive inputs.
|
Pair<Hop[],CNodeTpl> |
TemplateRow.constructCplan(Hop hop,
CPlanMemoTable memo,
boolean compileLiterals) |
Pair<Hop[],CNodeTpl> |
TemplateOuterProduct.constructCplan(Hop hop,
CPlanMemoTable memo,
boolean compileLiterals) |
Pair<Hop[],CNodeTpl> |
TemplateCell.constructCplan(Hop hop,
CPlanMemoTable memo,
boolean compileLiterals) |
Modifier and Type | Method and Description |
---|---|
Pair<MatrixObject,Boolean> |
ExecutionContext.getDenseMatrixOutputForGPUInstruction(String varName,
long numRows,
long numCols)
Allocates a dense matrix on the GPU (for output)
|
Pair<MatrixObject,Boolean> |
ExecutionContext.getSparseMatrixOutputForGPUInstruction(String varName,
long numRows,
long numCols,
long nnz)
Allocates a sparse matrix in CSR format on the GPU.
|
Modifier and Type | Method and Description |
---|---|
Pair<MatrixIndexes,Double> |
CTable.execute(long row,
double v2,
double w) |
Modifier and Type | Method and Description |
---|---|
void |
FrameReblockBuffer.flushBufferToBinaryBlocks(ArrayList<Pair<Long,FrameBlock>> outList) |
Modifier and Type | Method and Description |
---|---|
static Pair<MatrixIndexes,MatrixBlock> |
SparkUtils.fromIndexedMatrixBlockToPair(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<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,
DataCharacteristics mc,
boolean containsID,
Pair<String[],Types.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<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text> |
BinaryBlockToTextCellConverter.next() |
Pair<K2,V2> |
Converter.next() |
Pair<MatrixIndexes,MatrixCell> |
TextToBinaryCellConverter.next() |
Modifier and Type | Method and Description |
---|---|
static void |
OperationsOnMatrixValues.performShift(Pair<Long,FrameBlock> in,
IndexRange ixrange,
int blenLeft,
long rlen,
long clen,
ArrayList<Pair<Long,FrameBlock>> outlist) |
static void |
OperationsOnMatrixValues.performSlice(Pair<Long,FrameBlock> in,
IndexRange ixrange,
int blen,
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,
IndexRange ixrange,
int blenLeft,
long rlen,
long clen,
ArrayList<Pair<Long,FrameBlock>> outlist) |
static void |
OperationsOnMatrixValues.performSlice(Pair<Long,FrameBlock> in,
IndexRange ixrange,
int blen,
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,
IndexRange range,
int rowCut) |
Modifier and Type | Method and Description |
---|---|
static void |
DecoderRecode.parseRecodeMapEntry(String entry,
Pair<String,String> pair)
Parses a line of <token, ID, count> into <token, ID> pairs, where
quoted tokens (potentially including separators) are supported.
|
Constructor and Description |
---|
TfOffsetMap(List<Pair<Long,Long>> rmRows) |
Modifier and Type | Method and Description |
---|---|
static IndexRange |
UtilFunctions.getSelectedRangeForZeroOut(Pair<Long,FrameBlock> in,
int blen,
IndexRange indexRange,
long lSrcRowIndex,
long lDestRowIndex) |
static int |
LocalFileUtils.readBlockSequenceFromLocal(String fname,
Pair<MatrixIndexes,MatrixValue>[] outValues,
HashMap<MatrixIndexes,Integer> outMap) |
static void |
LocalFileUtils.writeBlockSequenceToLocal(String fname,
Pair<MatrixIndexes,MatrixValue>[] inValues,
int len) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.