org.apache.hadoop.hive.ql.exec.tez

Class CustomVertexConfiguration

java.lang.Object

org.apache.hadoop.hive.ql.exec.tez.CustomVertexConfiguration

All Implemented Interfaces:

org.apache.hadoop.io.Writable

public class CustomVertexConfiguration
extends Object
implements org.apache.hadoop.io.Writable

Constructor Summary

Constructors

Constructor and Description
CustomVertexConfiguration()
CustomVertexConfiguration(int numBuckets, TezWork.VertexType vertexType)
CustomVertexConfiguration(int numBuckets, TezWork.VertexType vertexType, String inputName, int numInputs, Map<String,Integer> inputToBucketMap)

Method Summary

Modifier and Type	Method and Description
String	getInputName()
Map<String,Integer>	getInputToBucketMap()
int	getNumBuckets()
int	getNumInputs()
TezWork.VertexType	getVertexType()
void	readFields(DataInput in)
void	write(DataOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomVertexConfiguration

public CustomVertexConfiguration()

CustomVertexConfiguration

public CustomVertexConfiguration(int numBuckets,
                                 TezWork.VertexType vertexType)

CustomVertexConfiguration

public CustomVertexConfiguration(int numBuckets,
                                 TezWork.VertexType vertexType,
                                 String inputName,
                                 int numInputs,
                                 Map<String,Integer> inputToBucketMap)

Method Detail

write

public void write(DataOutput out)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException

getNumBuckets

public int getNumBuckets()

getVertexType

public TezWork.VertexType getVertexType()

getInputName

public String getInputName()

getNumInputs

public int getNumInputs()

getInputToBucketMap

public Map<String,Integer> getInputToBucketMap()