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:

java.io.Serializable

public class TezEdgeDescriptor
extends java.lang.Object
implements java.io.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
java.lang.String	inputClassName
java.lang.String	outputClassName
java.lang.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
java.lang.Boolean	getCombinerInMap()
java.lang.Boolean	getCombinerInReducer()
java.lang.String	getIntermediateOutputKeyClass()
java.lang.String	getIntermediateOutputKeyComparatorClass()
java.lang.String	getIntermediateOutputValueClass()
boolean[]	getSecondarySortOrder()
boolean	isUseSecondaryKey()
boolean	needsDistinctCombiner()
void	setCombinerInMap(java.lang.Boolean combinerInMap)
void	setCombinerInReducer(java.lang.Boolean combinerInReducer)
void	setIntermediateOutputKeyClass(java.lang.String intermediateOutputKeyClass)
void	setIntermediateOutputKeyComparatorClass(java.lang.String intermediateOutputKeyComparatorClass)
void	setIntermediateOutputValueClass(java.lang.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 java.lang.String inputClassName

outputClassName

public java.lang.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 java.lang.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 java.lang.Boolean getCombinerInMap()

setCombinerInMap

public void setCombinerInMap(java.lang.Boolean combinerInMap)

getCombinerInReducer

public java.lang.Boolean getCombinerInReducer()

setCombinerInReducer

public void setCombinerInReducer(java.lang.Boolean combinerInReducer)

isUseSecondaryKey

public boolean isUseSecondaryKey()

setUseSecondaryKey

public void setUseSecondaryKey(boolean useSecondaryKey)

getSecondarySortOrder

public boolean[] getSecondarySortOrder()

setSecondarySortOrder

public void setSecondarySortOrder(boolean[] secondarySortOrder)

getIntermediateOutputKeyClass

public java.lang.String getIntermediateOutputKeyClass()

setIntermediateOutputKeyClass

public void setIntermediateOutputKeyClass(java.lang.String intermediateOutputKeyClass)

getIntermediateOutputValueClass

public java.lang.String getIntermediateOutputValueClass()

setIntermediateOutputValueClass

public void setIntermediateOutputValueClass(java.lang.String intermediateOutputValueClass)

getIntermediateOutputKeyComparatorClass

public java.lang.String getIntermediateOutputKeyComparatorClass()

setIntermediateOutputKeyComparatorClass

public void setIntermediateOutputKeyComparatorClass(java.lang.String intermediateOutputKeyComparatorClass)