dag restriction

v4

JobParamTemplate

ProcessNodeTemplate

-NodeTypeEnum nodeType

InnerStreamInputNode

List <Vertex> graph

FilterNode

-String priorNodeId-List<FilterContent> filterContentList-LogicalOperatorEnum logicalOperator-List<Attribute> outputSchema

ID

InputNode

-String dataSourceId-NodeTypeEnum nodeType

OutputNodeTemplate

-String priorNodeId -DbTypeEnum dbType;-NodeTyoeEnum nodeType

RealTimeParamTemplate

-List InputNodeTemplate-List ProcessNodetTemplate-List OutputNodeTemplate

v3

vertex

- String priorID- List < int > index

ProcessNode

v5

用户可以配置的最大任务数量 e.g. 3

e

InnerInputNode

-String deviceTypeId-List<String> deviceIdList-List<Attribute> outputSchema

NodeTemplate

-String nodeId-String nodeName

JobTemplate

-JobParamTemplate jobParamTemplate

priorId -> currentIdv1 -> v4v1 -> v3v2 -> v3v4 -> v3.......

OutputNode

-String priorNodeId-String dataSourceId-DbTypeEnum dbType-NodeTyoeEnum nodeType

running的任务中失败的数量

检查是否有孤立点：check if map.keyset().size() == graph.size()

InputNodeTemplate

Node

InnerInputNodeTemplate

-List<Attribute> outputSchema

类型

v2

JobParam

*KafakaOutputNode

v1

MySqlOutputNodeTemplate

-TimeAggregation timeAggregation-MySqlOutputMapper outputMapper

RealTimeJobParam

-List InputNode-List ProcessNode-List OutputNode

Job

-JobParam jobParam

DimensionalJoinNodeTemplate

-JoinTypeEnum joinType-String priorNodeId-AttributeMapper attributeMapper -List<Attribute> outputSchema

检查是否是DAG图：一条深度遍历路线中如果有结点被第二次访问到，那么有环

running的任务数量

KafkaOutputNode

currentID 一定不会重复：检查是否有重复IDcheck if currentID in map.keyset()

MySqlOutputNode

-TimeAggregation timeAggregation-String table-MySqlOutputMapper outputMapper

SqlNode

-String priorNodeId-String sql-List<Attribute> outputSchema

DimensionJoinNode

-JoinTypeEnum joinType-String priorNodeId-AttributeMapper attributeMapper-String dimensionDsId-String table-List<Attribute> outputSchema