org.apache.hadoop.hive.ql.plan

Class SparkEdgeProperty

java.lang.Object

org.apache.hadoop.hive.ql.plan.SparkEdgeProperty

public class SparkEdgeProperty
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static long	MR_SHUFFLE_SORT
static long	SHUFFLE_GROUP
static long	SHUFFLE_NONE
static long	SHUFFLE_SORT

Constructor Summary

Constructors

Constructor and Description
SparkEdgeProperty(long edgeType)
SparkEdgeProperty(long edgeType, int numPartitions)

Method Summary

Methods

Modifier and Type	Method and Description
long	getEdgeType()
int	getNumPartitions()
String	getShuffleType()
boolean	isMRShuffle()
boolean	isShuffleGroup()
boolean	isShuffleNone()
boolean	isShuffleSort()
void	setMRShuffle()
void	setNumPartitions(int numPartitions)
void	setShuffleGroup()
void	setShuffleNone()
void	setShuffleSort()

Methods inherited from class java.lang.Object

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

Field Detail

SHUFFLE_NONE

public static final long SHUFFLE_NONE

See Also:

Constant Field Values

SHUFFLE_GROUP

public static final long SHUFFLE_GROUP

See Also:

Constant Field Values

SHUFFLE_SORT

public static final long SHUFFLE_SORT

See Also:

Constant Field Values

MR_SHUFFLE_SORT

public static final long MR_SHUFFLE_SORT

See Also:

Constant Field Values

Constructor Detail

SparkEdgeProperty

public SparkEdgeProperty(long edgeType,
                 int numPartitions)

SparkEdgeProperty

public SparkEdgeProperty(long edgeType)

Method Detail

isShuffleNone

public boolean isShuffleNone()

setShuffleNone

public void setShuffleNone()

isShuffleGroup

public boolean isShuffleGroup()

setShuffleGroup

public void setShuffleGroup()

setMRShuffle

public void setMRShuffle()

isMRShuffle

public boolean isMRShuffle()

setShuffleSort

public void setShuffleSort()

isShuffleSort

public boolean isShuffleSort()

getEdgeType

public long getEdgeType()

getShuffleType

public String getShuffleType()

getNumPartitions

public int getNumPartitions()

setNumPartitions

public void setNumPartitions(int numPartitions)