Uses of Class
org.apache.nemo.compiler.optimizer.pass.runtime.Message

Packages that use Message

Package	Description
org.apache.nemo.compiler.optimizer
org.apache.nemo.compiler.optimizer.pass.runtime
org.apache.nemo.compiler.optimizer.policy

Uses of Message in org.apache.nemo.compiler.optimizer

Methods in org.apache.nemo.compiler.optimizer with parameters of type Message

Modifier and Type	Method	Description
IRDAG	NemoOptimizer.optimizeAtRunTime(IRDAG dag, Message message)
IRDAG	Optimizer.optimizeAtRunTime(IRDAG dag, Message message)	Optimize the submitted DAG at run time.

Uses of Message in org.apache.nemo.compiler.optimizer.pass.runtime

Methods in org.apache.nemo.compiler.optimizer.pass.runtime with parameters of type Message

Modifier and Type	Method	Description
IRDAG	DynamicTaskSizingRuntimePass.apply(IRDAG irdag, Message<java.util.Map<java.lang.String,java.lang.Long>> mapMessage)
IRDAG	SkewRunTimePass.apply(IRDAG irdag, Message<java.util.Map<java.lang.Object,java.lang.Long>> message)

Uses of Message in org.apache.nemo.compiler.optimizer.policy

Methods in org.apache.nemo.compiler.optimizer.policy with parameters of type Message

Modifier and Type	Method	Description
IRDAG	BasicPullPolicy.runRunTimeOptimizations(IRDAG dag, Message<?> message)
IRDAG	BasicPushPolicy.runRunTimeOptimizations(IRDAG dag, Message<?> message)
IRDAG	ConditionalLargeShufflePolicy.runRunTimeOptimizations(IRDAG dag, Message<?> message)
IRDAG	DataSkewPolicy.runRunTimeOptimizations(IRDAG dag, Message<?> message)
IRDAG	DefaultPolicy.runRunTimeOptimizations(IRDAG dag, Message<?> message)
IRDAG	DefaultPolicyWithSeparatePass.runRunTimeOptimizations(IRDAG dag, Message<?> message)
IRDAG	DisaggregationPolicy.runRunTimeOptimizations(IRDAG dag, Message<?> message)
IRDAG	DynamicTaskSizingPolicy.runRunTimeOptimizations(IRDAG dag, Message<?> message)
IRDAG	LambdaPolicy.runRunTimeOptimizations(IRDAG dag, Message<?> message)
IRDAG	LargeShufflePolicy.runRunTimeOptimizations(IRDAG dag, Message<?> message)
IRDAG	Policy.runRunTimeOptimizations(IRDAG dag, Message<?> message)	Optimize the DAG with the run-time optimizations.
IRDAG	PolicyImpl.runRunTimeOptimizations(IRDAG irdag, Message message)
IRDAG	SamplingLargeShuffleSkewPolicy.runRunTimeOptimizations(IRDAG dag, Message<?> message)
IRDAG	StreamingPolicy.runRunTimeOptimizations(IRDAG dag, Message<?> message)
IRDAG	TestPolicy.runRunTimeOptimizations(IRDAG dag, Message<?> message)
IRDAG	TransientResourcePolicy.runRunTimeOptimizations(IRDAG dag, Message<?> message)
IRDAG	XGBoostPolicy.runRunTimeOptimizations(IRDAG dag, Message<?> message)