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
