-
Notifications
You must be signed in to change notification settings - Fork 209
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
支持批量任务分布式执行 #157
Labels
enhancement
New feature or request
Milestone
Comments
powerJob相关https://github.com/PowerJob/PowerJob 利用powerJob 实现DAG任务定义:https://github.com/PowerJob/PowerJob/blob/805046dccbb9dbeb6a59b0fe12a3fe9f1beb9ae7/powerjob-client/src/test/java/tech/powerjob/client/test/TestWorkflow.java // DAG 图
List<PEWorkflowDAG.Node> nodes = Lists.newLinkedList();
List<PEWorkflowDAG.Edge> edges = Lists.newLinkedList();
nodes.add(new PEWorkflowDAG.Node(nodeList.get(0).getId()));
nodes.add(new PEWorkflowDAG.Node(nodeList.get(1).getId()));
nodes.add(new PEWorkflowDAG.Node(nodeList.get(2).getId()));
edges.add(new PEWorkflowDAG.Edge(nodeList.get(0).getId(), nodeList.get(1).getId()));
edges.add(new PEWorkflowDAG.Edge(nodeList.get(1).getId(), nodeList.get(2).getId()));
PEWorkflowDAG peWorkflowDAG = new PEWorkflowDAG(nodes, edges); 需要修改点
|
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
#97 has been referd
相关执行流程图
The text was updated successfully, but these errors were encountered: