org.apache.pig.backend.hadoop.executionengine.tez.plan

Class TezEdgeDescriptor

java.lang.Object

org.apache.pig.backend.hadoop.executionengine.tez.plan.TezEdgeDescriptor

All Implemented Interfaces:

Serializable

public class TezEdgeDescriptor
extends Object
implements Serializable

Descriptor for Tez edge. It holds combine plan as well as edge properties.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
PhysicalPlan	combinePlan
org.apache.tez.dag.api.EdgeProperty.DataMovementType	dataMovementType
org.apache.tez.dag.api.EdgeProperty.DataSourceType	dataSourceType
String	inputClassName
String	outputClassName
Class<? extends org.apache.hadoop.mapreduce.Partitioner>	partitionerClass
org.apache.tez.dag.api.EdgeProperty.SchedulingType	schedulingType

Constructor Summary

Constructors

Constructor and Description
TezEdgeDescriptor()

Method Summary

Methods

Modifier and Type	Method and Description
String	getIntermediateOutputKeyClass()
String	getIntermediateOutputKeyComparatorClass()
String	getIntermediateOutputValueClass()
boolean[]	getSecondarySortOrder()
boolean	isUseSecondaryKey()
boolean	needsDistinctCombiner()
void	setIntermediateOutputKeyClass(String intermediateOutputKeyClass)
void	setIntermediateOutputKeyComparatorClass(String intermediateOutputKeyComparatorClass)
void	setIntermediateOutputValueClass(String intermediateOutputValueClass)
void	setNeedsDistinctCombiner(boolean nic)
void	setSecondarySortOrder(boolean[] secondarySortOrder)
void	setUseSecondaryKey(boolean useSecondaryKey)

Methods inherited from class java.lang.Object

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

Field Detail

combinePlan

public transient PhysicalPlan combinePlan

inputClassName

public String inputClassName

outputClassName

public String outputClassName

schedulingType

public org.apache.tez.dag.api.EdgeProperty.SchedulingType schedulingType

dataSourceType

public org.apache.tez.dag.api.EdgeProperty.DataSourceType dataSourceType

dataMovementType

public org.apache.tez.dag.api.EdgeProperty.DataMovementType dataMovementType

partitionerClass

public Class<? extends org.apache.hadoop.mapreduce.Partitioner> partitionerClass

Constructor Detail

TezEdgeDescriptor

public TezEdgeDescriptor()

Method Detail

needsDistinctCombiner

public boolean needsDistinctCombiner()

setNeedsDistinctCombiner

public void setNeedsDistinctCombiner(boolean nic)

isUseSecondaryKey

public boolean isUseSecondaryKey()

setUseSecondaryKey

public void setUseSecondaryKey(boolean useSecondaryKey)

getSecondarySortOrder

public boolean[] getSecondarySortOrder()

setSecondarySortOrder

public void setSecondarySortOrder(boolean[] secondarySortOrder)

getIntermediateOutputKeyClass

public String getIntermediateOutputKeyClass()

setIntermediateOutputKeyClass

public void setIntermediateOutputKeyClass(String intermediateOutputKeyClass)

getIntermediateOutputValueClass

public String getIntermediateOutputValueClass()

setIntermediateOutputValueClass

public void setIntermediateOutputValueClass(String intermediateOutputValueClass)

getIntermediateOutputKeyComparatorClass

public String getIntermediateOutputKeyComparatorClass()

setIntermediateOutputKeyComparatorClass

public void setIntermediateOutputKeyComparatorClass(String intermediateOutputKeyComparatorClass)