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

Packages that use ExecutionProperty

Package	Description
org.apache.nemo.common.ir.edge.executionproperty
org.apache.nemo.common.ir.executionproperty
org.apache.nemo.common.ir.vertex.executionproperty
org.apache.nemo.compiler.optimizer.pass.compiletime
org.apache.nemo.compiler.optimizer.pass.compiletime.annotating
org.apache.nemo.compiler.optimizer.pass.compiletime.composite
org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping
org.apache.nemo.runtime.common.metric

Uses of ExecutionProperty in org.apache.nemo.common.ir.edge.executionproperty

Subclasses of ExecutionProperty in org.apache.nemo.common.ir.edge.executionproperty

Modifier and Type	Class	Description
class	AdditionalOutputTagProperty	Additional Output Tag Execution Property for edge that contains tag for additional outputs.
class	BlockFetchFailureProperty	Decides how to react to a data block fetch failure.
class	CacheIDProperty	Cache ID ExecutionProperty.
class	CommunicationPatternProperty	DataCommunicationPattern ExecutionProperty.
class	CompressionProperty	Compression ExecutionProperty.
class	DataFlowProperty	DataFlowModel ExecutionProperty.
class	DataPersistenceProperty	Data persistence ExecutionProperty.
class	DataStoreProperty	DataStore ExecutionProperty.
class	DecoderProperty	Decoder ExecutionProperty.
class	DecompressionProperty	Decompression ExecutionProperty.
class	DuplicateEdgeGroupProperty	Invariant data ExecutionProperty.
class	EncoderProperty	Encoder ExecutionProperty.
class	KeyDecoderProperty	KeyDecoder ExecutionProperty.
class	KeyEncoderProperty	KeyEncoder ExecutionProperty.
class	KeyExtractorProperty	KeyExtractor ExecutionProperty.
class	MessageIdEdgeProperty	Vertices and edges with the same MessageId are subject to the same run-time optimization.
class	PartitionerProperty	Partitioner ExecutionProperty.
class	PartitionSetProperty	This property decides which partitions the tasks of the destination IRVertex should fetch.
class	SubPartitionSetProperty	This property decides the hash partition set of sampled and optimized tasks in Dynamic Task Sizing Policy.

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

Classes in org.apache.nemo.common.ir.executionproperty with type parameters of type ExecutionProperty

Modifier and Type	Class	Description
class	ExecutionPropertyMap<T extends ExecutionProperty>	ExecutionPropertyMap Class, which uses HashMap for keeping track of ExecutionProperties for vertices and edges.

Subclasses of ExecutionProperty in org.apache.nemo.common.ir.executionproperty

Modifier and Type	Class	Description
class	EdgeExecutionProperty<T extends java.io.Serializable>	ExecutionProperty for IREdge.
class	VertexExecutionProperty<T extends java.io.Serializable>	ExecutionProperty for IRVertex.

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

Modifier and Type	Method	Description
java.lang.Class<? extends ExecutionProperty>	value()

Method parameters in org.apache.nemo.common.ir.executionproperty with type arguments of type ExecutionProperty

Modifier and Type	Method	Description
<U extends java.io.Serializable> java.util.Optional<U>	ExecutionPropertyMap.get(java.lang.Class<? extends ExecutionProperty<U>> executionPropertyKey)	Get the value of the given execution property type.

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

Subclasses of ExecutionProperty 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 ExecutionProperty in org.apache.nemo.compiler.optimizer.pass.compiletime

Methods in org.apache.nemo.compiler.optimizer.pass.compiletime that return types with arguments of type ExecutionProperty

Modifier and Type	Method	Description
abstract java.util.Set<java.lang.Class<? extends ExecutionProperty>>	CompileTimePass.getPrerequisiteExecutionProperties()	Getter for prerequisite execution properties.
java.lang.Class<? extends ExecutionProperty>[]	value()

Uses of ExecutionProperty in org.apache.nemo.compiler.optimizer.pass.compiletime.annotating

Methods in org.apache.nemo.compiler.optimizer.pass.compiletime.annotating that return types with arguments of type ExecutionProperty

Modifier and Type	Method	Description
java.util.Set<java.lang.Class<? extends ExecutionProperty>>	AnnotatingPass.getExecutionPropertiesToAnnotate()	Getter for the execution properties to annotate through the pass.
java.util.Set<java.lang.Class<? extends ExecutionProperty>>	AnnotatingPass.getPrerequisiteExecutionProperties()
java.lang.Class<? extends ExecutionProperty>[]	value()

Uses of ExecutionProperty in org.apache.nemo.compiler.optimizer.pass.compiletime.composite

Methods in org.apache.nemo.compiler.optimizer.pass.compiletime.composite that return types with arguments of type ExecutionProperty

Modifier and Type	Method	Description
java.util.Set<java.lang.Class<? extends ExecutionProperty>>	CompositePass.getPrerequisiteExecutionProperties()

Uses of ExecutionProperty in org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping

Methods in org.apache.nemo.compiler.optimizer.pass.compiletime.reshaping that return types with arguments of type ExecutionProperty

Modifier and Type	Method	Description
java.util.Set<java.lang.Class<? extends ExecutionProperty>>	ReshapingPass.getPrerequisiteExecutionProperties()

Uses of ExecutionProperty in org.apache.nemo.runtime.common.metric

Methods in org.apache.nemo.runtime.common.metric that return ExecutionProperty

Modifier and Type	Method	Description
static ExecutionProperty<? extends java.io.Serializable>	MetricUtils.keyAndValueToEP(java.lang.Integer epKeyIndex, java.lang.Double split, java.lang.Double tweak)	Receives the pair of execution property and value classes, and returns the optimized value of the EP.

Method parameters in org.apache.nemo.runtime.common.metric with type arguments of type ExecutionProperty

Modifier and Type	Method	Description
static java.util.Optional<java.lang.reflect.Method>	MetricUtils.getMethodFor(java.lang.Class<? extends ExecutionProperty> clazz, java.lang.String name, java.lang.Class<?>... valueTypes)	Utility method to getting an optional method called 'name' for the class.