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

Class TezOperator.VertexGroupInfo

java.lang.Object

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

Enclosing class:

TezOperator

public static class TezOperator.VertexGroupInfo
extends Object

Constructor Summary

Constructors

Constructor and Description
TezOperator.VertexGroupInfo()
TezOperator.VertexGroupInfo(POStore store)

Method Summary

Methods

Modifier and Type	Method and Description
void	addInput(OperatorKey input)
List<OperatorKey>	getInputs()
String	getOutput()
FileSpec	getSFile()
POStore	getStore()
org.apache.tez.dag.api.OutputDescriptor	getStoreOutputDescriptor()
org.apache.tez.dag.api.VertexGroup	getVertexGroup()
boolean	removeInput(OperatorKey input)
void	setOutput(String output)
void	setSFile(FileSpec sFile)
void	setStoreOutputDescriptor(org.apache.tez.dag.api.OutputDescriptor storeOutDescriptor)
void	setVertexGroup(org.apache.tez.dag.api.VertexGroup vertexGroup)

Methods inherited from class java.lang.Object

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

Constructor Detail

TezOperator.VertexGroupInfo

public TezOperator.VertexGroupInfo()

TezOperator.VertexGroupInfo

public TezOperator.VertexGroupInfo(POStore store)

Method Detail

getInputs

public List<OperatorKey> getInputs()

addInput

public void addInput(OperatorKey input)

removeInput

public boolean removeInput(OperatorKey input)

getOutput

public String getOutput()

setOutput

public void setOutput(String output)

getStore

public POStore getStore()

getStoreOutputDescriptor

public org.apache.tez.dag.api.OutputDescriptor getStoreOutputDescriptor()

setStoreOutputDescriptor

public void setStoreOutputDescriptor(org.apache.tez.dag.api.OutputDescriptor storeOutDescriptor)

getVertexGroup

public org.apache.tez.dag.api.VertexGroup getVertexGroup()

setVertexGroup

public void setVertexGroup(org.apache.tez.dag.api.VertexGroup vertexGroup)

setSFile

public void setSFile(FileSpec sFile)

getSFile

public FileSpec getSFile()