Uses of Class
org.apache.nemo.common.ir.executionproperty.VertexExecutionProperty

Packages that use VertexExecutionProperty

Package	Description
org.apache.nemo.common.ir.executionproperty
org.apache.nemo.common.ir.vertex
org.apache.nemo.common.ir.vertex.executionproperty
org.apache.nemo.runtime.common.plan
org.apache.nemo.runtime.master.scheduler

Uses of VertexExecutionProperty in org.apache.nemo.common.ir.executionproperty

Methods in org.apache.nemo.common.ir.executionproperty that return types with arguments of type VertexExecutionProperty

Modifier and Type	Method	Description
static ExecutionPropertyMap<VertexExecutionProperty>	ExecutionPropertyMap.of(IRVertex irVertex)	Static initializer for irVertex.

Uses of VertexExecutionProperty in org.apache.nemo.common.ir.vertex

Methods in org.apache.nemo.common.ir.vertex that return types with arguments of type VertexExecutionProperty

Modifier and Type	Method	Description
ExecutionPropertyMap<VertexExecutionProperty>	IRVertex.getExecutionProperties()

Methods in org.apache.nemo.common.ir.vertex with parameters of type VertexExecutionProperty

Modifier and Type	Method	Description
IRVertex	IRVertex.setProperty(VertexExecutionProperty<?> executionProperty)	Set an executionProperty of the IRVertex.
IRVertex	IRVertex.setPropertyPermanently(VertexExecutionProperty<?> executionProperty)	Set an executionProperty of the IRVertex, permanently.

Method parameters in org.apache.nemo.common.ir.vertex with type arguments of type VertexExecutionProperty

Modifier and Type	Method	Description
<T extends java.io.Serializable> java.util.Optional<T>	IRVertex.getPropertyValue(java.lang.Class<? extends VertexExecutionProperty<T>> executionPropertyKey)	Get the executionProperty of the IRVertex.

Uses of VertexExecutionProperty in org.apache.nemo.common.ir.vertex.executionproperty

Subclasses of VertexExecutionProperty in org.apache.nemo.common.ir.vertex.executionproperty

Modifier and Type	Class	Description
class	ClonedSchedulingProperty	Specifies cloned execution of a vertex.
class	EnableDynamicTaskSizingProperty	Property to enable dynamic task sizing policy.
class	IgnoreSchedulingTempDataReceiverProperty	A property represents that a vertex annotated with this property doesn't process any data and should be regarded as a kind of "marker" to construct a temporary edge that contains some data that have to be written before it's usage is not determined (e.g., for caching).
class	MessageIdVertexProperty	Vertices and edges with the same MessageId belong to the same run-time optimization.
class	ParallelismProperty	This property decides the number of parallel tasks to use for executing the corresponding IRVertex.
class	ResourceAntiAffinityProperty	Indices of tasks that must not concurrently run on the same executor.
class	ResourceLambdaProperty	Resource property supporting Lambda Pass.
class	ResourceLocalityProperty	This property decides whether or not to schedule this vertex only on executors where source (including intermediate) data reside.
class	ResourcePriorityProperty	ExecutionPlacement ExecutionProperty.
class	ResourceSiteProperty	Map between node name and the number of parallelism which will run on the node.
class	ResourceSlotProperty	This property decides whether or not to comply to slot restrictions when scheduling this vertex.
class	ScheduleGroupProperty	ScheduleGroup ExecutionProperty.

Uses of VertexExecutionProperty in org.apache.nemo.runtime.common.plan

Methods in org.apache.nemo.runtime.common.plan that return types with arguments of type VertexExecutionProperty

Modifier and Type	Method	Description
ExecutionPropertyMap<VertexExecutionProperty>	Stage.getExecutionProperties()
ExecutionPropertyMap<VertexExecutionProperty>	Task.getExecutionProperties()
java.util.Set<VertexExecutionProperty>	StagePartitioner.getStageProperties(IRVertex vertex)

Method parameters in org.apache.nemo.runtime.common.plan with type arguments of type VertexExecutionProperty

Modifier and Type	Method	Description
void	StagePartitioner.addIgnoredPropertyKey(java.lang.Class<? extends VertexExecutionProperty> ignoredPropertyKey)	By default, the stage partitioner merges two vertices into one stage if and only if the two vertices have same set of VertexExecutionProperty.
<T extends java.io.Serializable> java.util.Optional<T>	Stage.getPropertyValue(java.lang.Class<? extends VertexExecutionProperty<T>> executionPropertyKey)	Get the executionProperty of the IREdge.
<T extends java.io.Serializable> java.util.Optional<T>	Task.getPropertyValue(java.lang.Class<? extends VertexExecutionProperty<T>> executionPropertyKey)	Get the executionProperty of this task.
void	Stage.setExecutionProperties(ExecutionPropertyMap<VertexExecutionProperty> executionProperties)

Constructor parameters in org.apache.nemo.runtime.common.plan with type arguments of type VertexExecutionProperty

Constructor	Description
Stage(java.lang.String stageId, java.util.List<java.lang.Integer> taskIndices, DAG<IRVertex,RuntimeEdge<IRVertex>> irDag, ExecutionPropertyMap<VertexExecutionProperty> executionProperties, java.util.List<java.util.Map<java.lang.String,Readable>> vertexIdToReadables)	Constructor.
Task(java.lang.String planId, java.lang.String taskId, ExecutionPropertyMap<VertexExecutionProperty> executionProperties, byte[] serializedIRDag, java.util.List<StageEdge> taskIncomingEdges, java.util.List<StageEdge> taskOutgoingEdges, java.util.Map<java.lang.String,Readable> irVertexIdToReadable)	Constructor.

Uses of VertexExecutionProperty in org.apache.nemo.runtime.master.scheduler

Method parameters in org.apache.nemo.runtime.master.scheduler with type arguments of type VertexExecutionProperty

Modifier and Type	Method	Description
java.util.Optional<SchedulingConstraint>	SchedulingConstraintRegistry.get(java.lang.Class<? extends VertexExecutionProperty> propertyClass)	Returns SchedulingConstraint for the given VertexExecutionProperty.