public abstract class DagJsonParser extends Object implements JsonParser
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 and Description |
---|
DagJsonParser() |
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) |
protected final org.slf4j.Logger LOG
public final Map<Op,List<Connection>> inlineMap
public boolean rewriteObject
public void extractStagesAndPlans(org.json.JSONObject inputObject) throws Exception
Exception
public static String prefixString(int indentFlag)
indentFlag
- help to generate correct indentpublic static String prefixString(int indentFlag, String tail)
indentFlag
- tail
- help to generate correct indent with a specific tailpublic void print(org.json.JSONObject inputObject, PrintStream outputStream) throws Exception
print
in interface JsonParser
Exception
public void addInline(Op op, Connection connection)
public boolean isInline(Vertex v)
public abstract String getFrameworkName()
Copyright © 2022 The Apache Software Foundation. All rights reserved.