edu.snu.coral.common.ir.vertex

Class MetricCollectionBarrierVertex<T>

java.lang.Object

edu.snu.coral.common.dag.Vertex

edu.snu.coral.common.ir.vertex.IRVertex

edu.snu.coral.common.ir.vertex.MetricCollectionBarrierVertex<T>

Type Parameters:

T - type of the metric data.

All Implemented Interfaces:

Serializable

public final class MetricCollectionBarrierVertex<T>
extends IRVertex

IRVertex that collects statistics to send them to the optimizer for dynamic optimization. This class is generated in the DAG through {edu.snu.coral.compiler.optimizer.pass.compiletime.composite.DataSkewCompositePass}.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MetricCollectionBarrierVertex() Constructor for dynamic optimization vertex.

Method Summary

Modifier and Type	Method and Description
void	accumulateMetric(String key, List<T> values) Method for accumulating metrics in the vertex.
MetricCollectionBarrierVertex	getClone()
DAG<IRVertex,IREdge>	getDAGSnapshot() Access the DAG snapshot when triggering dynamic optimization.
Map<String,List<T>>	getMetricData() Method for retrieving metrics from the vertex.
String	propertiesToJSON()
void	setDAGSnapshot(DAG<IRVertex,IREdge> dag) This is to set the DAG snapshot at the end of the DataSkewCompositePass.

Methods inherited from class edu.snu.coral.common.ir.vertex.IRVertex

copyExecutionPropertiesTo, getExecutionProperties, getProperty, irVertexPropertiesToString, setProperty

Methods inherited from class edu.snu.coral.common.dag.Vertex

getId, getNumericId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MetricCollectionBarrierVertex

public MetricCollectionBarrierVertex()

Constructor for dynamic optimization vertex.

Method Detail

getClone

public MetricCollectionBarrierVertex getClone()

Specified by:

getClone in class IRVertex

Returns:

a clone elemnt of the IRVertex.

setDAGSnapshot

public void setDAGSnapshot(DAG<IRVertex,IREdge> dag)

This is to set the DAG snapshot at the end of the DataSkewCompositePass.

Parameters:

dag - DAG to set on the vertex.

getDAGSnapshot

public DAG<IRVertex,IREdge> getDAGSnapshot()

Access the DAG snapshot when triggering dynamic optimization.

Returns:

the DAG set to the vertex, or throws an exception otherwise.

accumulateMetric

public void accumulateMetric(String key,
                             List<T> values)

Method for accumulating metrics in the vertex.

Parameters:

key - metric key, e.g. ID of the partition.

values - metric values, e.g. the block size information of the partition data.

getMetricData

public Map<String,List<T>> getMetricData()

Method for retrieving metrics from the vertex.

Returns:

the accumulated metric data.

propertiesToJSON

public String propertiesToJSON()

Overrides:

propertiesToJSON in class Vertex

Returns:

JSON representation of additional properties