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 © 2020 The Apache Software Foundation. All rights reserved.