org.apache.hadoop.hive.common.jsonexplain

Class DagJsonParser

java.lang.Object

org.apache.hadoop.hive.common.jsonexplain.DagJsonParser

All Implemented Interfaces:

JsonParser

Direct Known Subclasses:

SparkJsonParser, TezJsonParser

public abstract class DagJsonParser
extends Object
implements JsonParser

Field Summary

Fields

Modifier and Type	Field and Description
Map<Op,List<Connection>>	inlineMap
protected org.slf4j.Logger	LOG
Set<Object>	printSet
boolean	rewriteObject
Map<String,Stage>	stages

Constructor Summary

Constructors

Constructor and Description
DagJsonParser()

Method Summary

Modifier and Type	Method and Description
void	addInline(Op op, Connection connection)
void	extractStagesAndPlans(org.json.JSONObject inputObject)
abstract String	getFrameworkName()
boolean	isInline(Vertex v)
abstract String	mapEdgeType(String edgeName)
static String	prefixString(int indentFlag)
static String	prefixString(int indentFlag, String tail)
void	print(org.json.JSONObject inputObject, PrintStream outputStream)

Methods inherited from class java.lang.Object

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

Field Detail

stages

public final Map<String,Stage> stages

LOG

protected final org.slf4j.Logger LOG

printSet

public final Set<Object> printSet

inlineMap

public final Map<Op,List<Connection>> inlineMap

rewriteObject

public boolean rewriteObject

Constructor Detail

DagJsonParser

public DagJsonParser()

Method Detail

extractStagesAndPlans

public void extractStagesAndPlans(org.json.JSONObject inputObject)
                           throws Exception

Throws:

Exception

prefixString

public static String prefixString(int indentFlag)

Parameters:

indentFlag - help to generate correct indent

Returns:

prefixString

public static String prefixString(int indentFlag,
                                  String tail)

Parameters:

indentFlag -

tail - help to generate correct indent with a specific tail

Returns:

print

public void print(org.json.JSONObject inputObject,
                  PrintStream outputStream)
           throws Exception

Specified by:

print in interface JsonParser

Throws:

Exception

addInline

public void addInline(Op op,
                      Connection connection)

isInline

public boolean isInline(Vertex v)

mapEdgeType

public abstract String mapEdgeType(String edgeName)

getFrameworkName

public abstract String getFrameworkName()