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

Modifier and Type	Method and Description
Boolean	getCombinerInMap()
Boolean	getCombinerInReducer()
String	getIntermediateOutputKeyClass()
String	getIntermediateOutputKeyComparatorClass()
String	getIntermediateOutputValueClass()
boolean[]	getSecondarySortOrder()
boolean	isUseSecondaryKey()
boolean	needsDistinctCombiner()
void	setCombinerInMap(Boolean combinerInMap)
void	setCombinerInReducer(Boolean combinerInReducer)
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)

getCombinerInMap

public Boolean getCombinerInMap()

setCombinerInMap

public void setCombinerInMap(Boolean combinerInMap)

getCombinerInReducer

public Boolean getCombinerInReducer()

setCombinerInReducer

public void setCombinerInReducer(Boolean combinerInReducer)

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)