Uses of Class
org.apache.nemo.common.Pair

Packages that use Pair

Package	Description
org.apache.nemo.common
org.apache.nemo.common.coder
org.apache.nemo.common.ir
org.apache.nemo.common.ir.edge.executionproperty
org.apache.nemo.common.ir.vertex.transform
org.apache.nemo.compiler.optimizer
org.apache.nemo.runtime.common.metric
org.apache.nemo.runtime.master

Uses of Pair in org.apache.nemo.common

Methods in org.apache.nemo.common that return Pair

Modifier and Type	Method	Description
static <A,B> Pair<A,B>	Pair.of(A left, B right)	Static initializer of the Pair class.

Methods in org.apache.nemo.common that return types with arguments of type Pair

Modifier and Type	Method	Description
static java.util.List<Pair<java.lang.Integer,ResourceSpecification>>	Util.parseResourceSpecificationString(java.lang.String resourceSpecificationString)	Utility method for parsing the resource specification string.

Uses of Pair in org.apache.nemo.common.coder

Methods in org.apache.nemo.common.coder that return types with arguments of type Pair

Modifier and Type	Method	Description
DecoderFactory.Decoder<Pair<A,B>>	PairDecoderFactory.create(java.io.InputStream inputStream)
EncoderFactory.Encoder<Pair<A,B>>	PairEncoderFactory.create(java.io.OutputStream outputStream)

Uses of Pair in org.apache.nemo.common.ir

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

Modifier and Type	Method	Description
java.util.List<Pair<java.lang.Integer,ResourceSpecification>>	IRDAG.getExecutorInfo()	Getter for the executor specifications information.

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

Modifier and Type	Method	Description
void	IRDAG.recordExecutorInfo(java.util.List<Pair<java.lang.Integer,ResourceSpecification>> parsedExecutorInfo)	Setter for the executor specifications information.

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

Methods in org.apache.nemo.common.ir.edge.executionproperty with parameters of type Pair

Modifier and Type	Method	Description
static PartitionerProperty	PartitionerProperty.of(Pair<PartitionerProperty.Type,java.lang.Integer> value)	Static constructor.

Uses of Pair in org.apache.nemo.common.ir.vertex.transform

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

Modifier and Type	Method	Description
void	MessageAggregatorTransform.onData(Pair<K,V> element)

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

Modifier and Type	Method	Description
void	MessageGeneratorTransform.prepare(Transform.Context context, OutputCollector<Pair<K,V>> oc)

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

Methods in org.apache.nemo.compiler.optimizer that return Pair

Modifier and Type	Method	Description
static Pair<java.lang.String,java.lang.Integer>	OptimizerUtils.stringToIdAndEPKeyIndex(java.lang.String string)	Restore the formatted string into a pair of vertex/edge id and the execution property.

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

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

Modifier and Type	Method	Description
static Pair<java.lang.String,java.lang.String>	MetricUtils.stringifyIRDAGProperties(IRDAG irdag)	Stringify execution properties of an IR DAG.

Uses of Pair in org.apache.nemo.runtime.master

Methods in org.apache.nemo.runtime.master that return Pair

Modifier and Type	Method	Description
Pair<PlanStateManager,java.util.concurrent.ScheduledExecutorService>	RuntimeMaster.execute(PhysicalPlan plan, int maxScheduleAttempt)	Submits the PhysicalPlan to Runtime.