| Modifier and Type | Method and Description | 
|---|---|
ParForProgramBlock.PartitionFormat | 
ParForStatementBlock.determineDataPartitionFormat(String var)
Determines the PDataPartitioningFormat for read-only parent variables according
 to the access pattern of that variable within the parfor statement block. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
static ParForProgramBlock.PartitionFormat | 
ParForProgramBlock.PartitionFormat.COLUMN_WISE  | 
static ParForProgramBlock.PartitionFormat | 
ParForProgramBlock.PartitionFormat.NONE  | 
static ParForProgramBlock.PartitionFormat | 
ParForProgramBlock.PartitionFormat.ROW_WISE  | 
| Modifier and Type | Method and Description | 
|---|---|
static ParForProgramBlock.PartitionFormat | 
ParForProgramBlock.PartitionFormat.valueOf(String value)  | 
| Modifier and Type | Method and Description | 
|---|---|
static RemoteParForJobReturn | 
RemoteDPParForSpark.runJob(long pfid,
      String itervar,
      String matrixvar,
      String program,
      HashMap<String,byte[]> clsMap,
      String resultFile,
      MatrixObject input,
      ExecutionContext ec,
      ParForProgramBlock.PartitionFormat dpf,
      Types.FileFormat fmt,
      boolean tSparseCol,
      boolean enableCPCaching,
      int numReducers)  | 
| Constructor and Description | 
|---|
DataPartitionerLocal(ParForProgramBlock.PartitionFormat dpf,
                    int par)
DataPartitionerLocal constructor. 
 | 
DataPartitionerRemoteSpark(ParForProgramBlock.PartitionFormat dpf,
                          ExecutionContext ec,
                          long numRed,
                          int replication,
                          boolean keepIndexes)  | 
RemoteDPParForSparkWorker(String program,
                         HashMap<String,byte[]> clsMap,
                         String inputVar,
                         String iterVar,
                         boolean cpCaching,
                         DataCharacteristics mc,
                         boolean tSparseCol,
                         ParForProgramBlock.PartitionFormat dpf,
                         Types.FileFormat fmt,
                         org.apache.spark.util.LongAccumulator atasks,
                         org.apache.spark.util.LongAccumulator aiters)  | 
| Modifier and Type | Method and Description | 
|---|---|
static boolean | 
OptimizerRuleBased.allowsBinaryCellPartitions(MatrixObject mo,
                          ParForProgramBlock.PartitionFormat dpf)  | 
Copyright © 2021 The Apache Software Foundation. All rights reserved.