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

Class TezEdgeDescriptor

java.lang.Object

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

public class TezEdgeDescriptor
extends java.lang.Object

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TezEdgeDescriptor()

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getIntermediateOutputKeyClass()
java.lang.String	getIntermediateOutputKeyComparatorClass()
java.lang.String	getIntermediateOutputValueClass()
boolean[]	getSecondarySortOrder()
boolean	isUseSecondaryKey()
void	setIntermediateOutputKeyClass(java.lang.String intermediateOutputKeyClass)
void	setIntermediateOutputKeyComparatorClass(java.lang.String intermediateOutputKeyComparatorClass)
void	setIntermediateOutputValueClass(java.lang.String intermediateOutputValueClass)
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 PhysicalPlan combinePlan

inputClassName

public java.lang.String inputClassName

outputClassName

public java.lang.String outputClassName

schedulingType

public SchedulingType schedulingType

dataSourceType

public DataSourceType dataSourceType

dataMovementType

public DataMovementType dataMovementType

partitionerClass

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

Constructor Detail

TezEdgeDescriptor

public TezEdgeDescriptor()

Method Detail

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)