| 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)  | 
static String | 
ProgramConverter.serializeProgram(Program prog,
                ArrayList<ProgramBlock> pbs,
                HashMap<String,byte[]> clsMap)  | 
| 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 © 2021 The Apache Software Foundation. All rights reserved.