| Modifier and Type | Method and Description | 
|---|---|
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> | 
TemplateMultiAgg.constructCplan(Hop hop,
              CPlanMemoTable memo,
              boolean compileLiterals)  | 
Pair<Hop[],CNodeTpl> | 
TemplateCell.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. 
 | 
| 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<Integer,Integer> | 
RawRow.findAtValue(ValueTrimFormat vtf,
           int rawIndex,
           int numericIndex)  | 
Pair<Integer,Integer> | 
RawRow.findAtValue(ValueTrimFormat vtf,
           int rawIndex,
           int numericIndex,
           boolean update)  | 
Pair<Integer,Integer> | 
RawRow.findSequenceValues(ArrayList<ValueTrimFormat> vtfs,
                  int startIndex,
                  boolean update)  | 
Pair<Integer,Integer> | 
RawRow.findValue(ValueTrimFormat vtf,
         boolean forward)  | 
Pair<Integer,Integer> | 
RawRow.findValue(ValueTrimFormat vtf,
         boolean forward,
         boolean update)  | 
Pair<String,String> | 
RawRow.getDelims()  | 
Pair<HashSet<String>,Integer> | 
RawRow.getDelimsSet()  | 
| Modifier and Type | Method and Description | 
|---|---|
Pair<K2,V2> | 
Converter.next()  | 
Pair<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text> | 
BinaryBlockToTextCellConverter.next()  | 
Pair<MatrixIndexes,MatrixCell> | 
TextToBinaryCellConverter.next()  | 
| Modifier and Type | Method and Description | 
|---|---|
static ArrayList<Pair<Long,FrameBlock>> | 
OperationsOnMatrixValues.performSlice(Pair<Long,FrameBlock> in,
            IndexRange ixrange,
            int blen)
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 ArrayList<Pair<Long,FrameBlock>> | 
OperationsOnMatrixValues.performSlice(Pair<Long,FrameBlock> in,
            IndexRange ixrange,
            int blen)
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)  | 
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 © 2021 The Apache Software Foundation. All rights reserved.