| 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.