Modifier and Type | Method and Description |
---|---|
static void |
ScriptExecutorUtils.executeRuntimeProgram(Program rtprog,
ExecutionContext ec,
DMLConfig dmlconf,
int statisticsMaxHeavyHitters,
Set<String> outputVariables)
Execute the runtime program.
|
Modifier and Type | Method and Description |
---|---|
static void |
JMLCUtils.cleanupRuntimeProgram(Program prog,
String[] outputs)
Removes rmvar instructions that would remove any of the given outputs.
|
Modifier and Type | Method and Description |
---|---|
Program |
ScriptExecutor.getRuntimeProgram()
Obtain the runtime program
|
Modifier and Type | Method and Description |
---|---|
static void |
MLContextUtil.deleteRemoveVariableInstructions(Program progam)
Delete the 'remove variable' instructions from a runtime program.
|
Modifier and Type | Method and Description |
---|---|
static void |
SpoofCompiler.generateCode(Program rtprog) |
Modifier and Type | Method and Description |
---|---|
static double |
CostEstimationWrapper.getTimeEstimate(Program rtprog,
ExecutionContext ec) |
double |
CostEstimator.getTimeEstimate(Program rtprog,
LocalVariableMap vars,
HashMap<String,VarStats> stats) |
Modifier and Type | Method and Description |
---|---|
Program |
DMLTranslator.getRuntimeProgram(DMLProgram prog,
DMLConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
DMLTranslator.codgenHopsDAG(Program rtprog) |
ProgramBlock |
DMLTranslator.createRuntimeProgramBlock(Program prog,
StatementBlock sb,
DMLConfig config) |
Modifier and Type | Method and Description |
---|---|
Program |
Program.clone(boolean deep) |
Program |
ProgramBlock.getProgram() |
Modifier and Type | Method and Description |
---|---|
void |
ProgramBlock.setProgram(Program prog) |
Constructor and Description |
---|
BasicProgramBlock(Program prog) |
ForProgramBlock(Program prog,
String iterPredVar) |
FunctionProgramBlock(Program prog,
List<DataIdentifier> inputParams,
List<DataIdentifier> outputParams) |
IfProgramBlock(Program prog,
ArrayList<Instruction> predicate) |
ParForProgramBlock(int ID,
Program prog,
String iterPredVar,
HashMap<String,String> params,
ArrayList<ParForStatementBlock.ResultVar> resultVars)
ParForProgramBlock constructor.
|
ParForProgramBlock(Program prog,
String iterPredVar,
HashMap<String,String> params,
ArrayList<ParForStatementBlock.ResultVar> resultVars) |
ProgramBlock(Program prog) |
WhileProgramBlock(Program prog,
ArrayList<Instruction> predicate) |
Modifier and Type | Method and Description |
---|---|
Program |
ExecutionContext.getProgram() |
Modifier and Type | Method and Description |
---|---|
static ExecutionContext |
ExecutionContextFactory.createContext(boolean allocateVars,
boolean allocateLineage,
Program prog) |
static ExecutionContext |
ExecutionContextFactory.createContext(boolean allocateVars,
Program prog) |
static ExecutionContext |
ExecutionContextFactory.createContext(LocalVariableMap vars,
Program prog) |
static ExecutionContext |
ExecutionContextFactory.createContext(Program prog) |
void |
ExecutionContext.setProgram(Program prog) |
Modifier and Type | Method and Description |
---|---|
static ArrayList<ProgramBlock> |
ProgramRecompiler.generatePartitialRuntimeProgram(Program rtprog,
ArrayList<StatementBlock> sbs) |
void |
OptTreePlanMappingAbstract.putRootProgram(DMLProgram prog,
Program rtprog) |
Modifier and Type | Method and Description |
---|---|
static Program |
ProgramConverter.parseProgram(String in,
int id) |
Modifier and Type | Method and Description |
---|---|
static ForProgramBlock |
ProgramConverter.createDeepCopyForProgramBlock(ForProgramBlock fpb,
long pid,
int IDPrefix,
Program prog,
Set<String> fnStack,
Set<String> fnCreated,
boolean plain,
boolean forceDeepCopy) |
static void |
ProgramConverter.createDeepCopyFunctionProgramBlock(String namespace,
String oldName,
long pid,
int IDPrefix,
Program prog,
Set<String> fnStack,
Set<String> fnCreated,
boolean plain)
This creates a deep copy of a function program block.
|
static IfProgramBlock |
ProgramConverter.createDeepCopyIfProgramBlock(IfProgramBlock ipb,
long pid,
int IDPrefix,
Program prog,
Set<String> fnStack,
Set<String> fnCreated,
boolean plain,
boolean forceDeepCopy) |
static ArrayList<Instruction> |
ProgramConverter.createDeepCopyInstructionSet(ArrayList<Instruction> instSet,
long pid,
int IDPrefix,
Program prog,
Set<String> fnStack,
Set<String> fnCreated,
boolean plain,
boolean cpFunctions)
Creates a deep copy of an array of instructions and replaces the placeholders of parworker
IDs with the concrete IDs of this parfor instance.
|
static ParForProgramBlock |
ProgramConverter.createDeepCopyParForProgramBlock(ParForProgramBlock pfpb,
long pid,
int IDPrefix,
Program prog,
Set<String> fnStack,
Set<String> fnCreated,
boolean plain,
boolean forceDeepCopy) |
static WhileProgramBlock |
ProgramConverter.createDeepCopyWhileProgramBlock(WhileProgramBlock wpb,
long pid,
int IDPrefix,
Program prog,
Set<String> fnStack,
Set<String> fnCreated,
boolean plain,
boolean forceDeepCopy) |
static ForProgramBlock |
ProgramConverter.createShallowCopyForProgramBlock(ForProgramBlock fpb,
Program prog) |
Modifier and Type | Method and Description |
---|---|
static Explain.ExplainCounts |
Explain.countDistributedOperations(Program rtprog)
Counts the number of compiled MRJob/Spark instructions in the
given runtime program.
|
static String |
Explain.display(DMLProgram prog,
Program rtprog,
Explain.ExplainType type,
Explain.ExplainCounts counts) |
static String |
Explain.explain(DMLProgram prog,
Program rtprog,
Explain.ExplainType type) |
static String |
Explain.explain(DMLProgram prog,
Program rtprog,
Explain.ExplainType type,
Explain.ExplainCounts counts) |
static String |
Explain.explain(Program rtprog) |
static String |
Explain.explain(Program rtprog,
Explain.ExplainCounts counts) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.