org.apache.hadoop.hive.common.jsonexplain

Class Vertex

java.lang.Object

org.apache.hadoop.hive.common.jsonexplain.Vertex

All Implemented Interfaces:

Comparable<Vertex>

public final class Vertex
extends Object
implements Comparable<Vertex>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Vertex.EdgeType
static class	Vertex.VertexType

Field Summary

Fields

Modifier and Type	Field and Description
List<Vertex>	children
boolean	dummy
String	edgeType
String	executionMode
List<Op>	inputOps
protected org.slf4j.Logger	LOG
List<Vertex>	mergeJoinDummyVertexs
String	name
int	numReduceOp
List<Op>	outputOps
List<Connection>	parentConnections
DagJsonParser	parser
Stage	stage
String	tag
Map<String,String>	tagToInput
org.json.JSONObject	vertexObject
Vertex.VertexType	vertexType

Constructor Summary

Constructors

Constructor and Description
Vertex(String name, org.json.JSONObject vertexObject, Stage stage, DagJsonParser dagJsonParser)

Method Summary

Modifier and Type	Method and Description
void	addDependency(Connection connection)
void	checkMultiReduceOperator(boolean rewriteObject) We check if a vertex has multiple reduce operators.
int	compareTo(Vertex o)
void	extractOpTree()
Op	getJoinRSOp(Vertex joinVertex)
void	print(Printer printer, int indentFlag, String type, Vertex callingVertex)
void	setType(String type)

Methods inherited from class java.lang.Object

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

Field Detail

name

public final String name

stage

public final Stage stage

parser

public final DagJsonParser parser

parentConnections

public final List<Connection> parentConnections

children

public final List<Vertex> children

vertexObject

public final org.json.JSONObject vertexObject

dummy

public boolean dummy

outputOps

public final List<Op> outputOps

inputOps

public final List<Op> inputOps

mergeJoinDummyVertexs

public final List<Vertex> mergeJoinDummyVertexs

numReduceOp

public int numReduceOp

executionMode

public String executionMode

tagToInput

public Map<String,String> tagToInput

tag

public String tag

LOG

protected final org.slf4j.Logger LOG

vertexType

public Vertex.VertexType vertexType

edgeType

public String edgeType

Constructor Detail

Vertex

public Vertex(String name,
              org.json.JSONObject vertexObject,
              Stage stage,
              DagJsonParser dagJsonParser)

Method Detail

addDependency

public void addDependency(Connection connection)
                   throws org.json.JSONException

Throws:

org.json.JSONException

extractOpTree

public void extractOpTree()
                   throws org.json.JSONException,
                          org.codehaus.jackson.JsonParseException,
                          org.codehaus.jackson.map.JsonMappingException,
                          IOException,
                          Exception

Throws:

org.json.JSONException

org.codehaus.jackson.JsonParseException

org.codehaus.jackson.map.JsonMappingException

IOException

Exception - We assume that there is a single top-level Map Operator Tree or a Reduce Operator Tree in a vertex

print

public void print(Printer printer,
                  int indentFlag,
                  String type,
                  Vertex callingVertex)
           throws org.json.JSONException,
                  Exception

Throws:

org.json.JSONException

Exception

checkMultiReduceOperator

public void checkMultiReduceOperator(boolean rewriteObject)
                              throws org.json.JSONException

We check if a vertex has multiple reduce operators.

Throws:

org.json.JSONException

setType

public void setType(String type)

compareTo

public int compareTo(Vertex o)

Specified by:

compareTo in interface Comparable<Vertex>

getJoinRSOp

public Op getJoinRSOp(Vertex joinVertex)