directed-acyclic-graphs 相关问题

有向非循环图出现在许多数据结构中,例如分布式版本控制系统中的变更集图。

指出dag的界限的索引 我正在编写一个程序,以找到最长的DAG路径,并带有标准的输入。我终于让它进行了编译,它说它由于我的数组列表,BU ...

import java.io.*; import java.util.*; public class countLongPaths { static final int NINF = Integer.MIN_VALUE; public class AdjListNode { private int v; private int weight; AdjListNode(int inV, int inW) { v = inV; weight = inW; } int getV() { return v; } int getWeight() { return weight; } }//end of adj list class public class Graph { private int V; private LinkedList<AdjListNode>adj[]; //set up graph with given number of verticies Graph(int v) { V=v; adj = new LinkedList[V]; for (int i = 0; i < v; ++i) adj[i] = new LinkedList<AdjListNode>(); } //function to add edges to graph void addEdge(int u, int v, int weight) { AdjListNode node = new AdjListNode(v,weight); adj[u].add(node);// Add v to u's list } //function to set order to go through vertices void setOrder(int v, Boolean visited[], Stack stack) { //Set node to visited when on it visited[v] = true; Integer i; //for all nodes connected to current repeat Iterator<AdjListNode> it = adj[v].iterator(); while (it.hasNext()) { AdjListNode node =it.next(); if (!visited[node.getV()]) setOrder(node.getV(), visited, stack); } //Once done with current add it to the stack stack.push(new Integer(v)); } //function to find longest paths from s int longestPath() { Stack stack = new Stack(); int LP[] = new int[V]; //set all vertices to unvisited Boolean visited[] = new Boolean[V]; for(int i = 1; i <= V; i++) visited[i] = false; //call set order function from each vertex for (int i = 1; i <= V; i++) { if(visited[i] == false) setOrder(i, visited, stack); } //initialize distaces to all verices as negative infinity //set distace to source to 0 LP[1] = 0; for(int i = 2; i <= V; i++) LP[i] = NINF; //go through vertices in order while(stack.empty() == false) { int u = (int)stack.pop(); //update LP for adj vertices Iterator<AdjListNode> it; if (LP[u] != NINF) { it = adj[u].iterator(); while (it.hasNext()) { AdjListNode i = it.next(); if(LP[i.getV()] < LP[u] + i.getWeight()) LP[i.getV()] = LP[u] + i.getWeight(); } } } return LP[V]; } }//end of graph class //Method to make a new graph public Graph newGraph(int number) { return new Graph(number); } public static void main(String[]args) { countLongPaths n = new countLongPaths(); int GN = 0; int count = 1; Scanner scan = new Scanner(System.in); GN = scan.nextInt(); while (count<= GN) { int N = 0;// nodes int M = 0;//edges N = scan.nextInt(); M = scan.nextInt(); //setup a new graph Graph g = n.newGraph(N); //set edges for new graph for(int i = 1; i <= M; i ++) { int I = scan.nextInt(); int J = scan.nextInt(); int W = scan.nextInt(); g.addEdge(I, J, W); } int dist = 0; dist = g.longestPath(); System.out.println("graph number: " + count); System.out.println("longest path: " + dist); System.out.println("number of longest paths: "); System.out.println(); count++; }//end of while }//end main }//end program

回答 1 投票 0


HourlyDAG ExternalTaskSensor检查外部DAG始终以“重新安排”模式

我有一个小时的dag(“ dag_b”)取决于外部dag的完整(“ dag_a”,也是一个小时的dag,比'execution_delta'中提到的“ dag_b”提前10分钟开始,因此想使用

回答 1 投票 0

最小化有向无环图中颜色过渡的贪婪算法

我正在使用有向无环图(DAG),其中: 一些节点已经分配了颜色(例如红色)。 有些节点是无色的,可以选择指定颜色。 输入和输出n...

回答 1 投票 0

使用数据感知调度来触发下游DAG,同时使用额外参数中包含的元数据作为下游DAG的参数

我目前有 2 个 DAG,其中包含可以设置为 run_date 的相同参数。我希望上游 DAG 使用入口和出口数据集触发下游 DAG,这看起来很直观......

回答 1 投票 0

DAG 中两个节点之间的路径数

我想找到 DAG 中两个节点之间的路径数。 O(V^2) 和 O(V+E) 是可以接受的。 O(V+E) 提醒我以某种方式使用 BFS 或 DFS,但我不知道如何使用。 有人可以帮忙吗?

回答 4 投票 0

从给定 DAG 中存在的每个节点开始可到达的节点总和,并限制每个节点的子节点数量

这是 XXX 波兰信息学奥林匹克竞赛第二阶段的一道题,题为“Wspinaczka”。波兰语原始问题陈述的链接。 让我们将上面的故事压缩成算法问题

回答 1 投票 0

如何使作业“b”在“a”之后运行,但仅当“a”成功时运行

在 Gitlab 中,有作业的 need 关键字,我可以用它来创建依赖项。 我真正不清楚的是我如何使工作 b 依赖于工作 a 但仅在工作 a 成功时才运行它(不...

回答 1 投票 0

将参数从 ECS 传递到 Airflow XCom

我想在Airflow中创建一个DAG来触发ECS任务。然后,此 ECS 任务将向 Airflow 返回一些参数,允许 DAG 使用这些参数触发下一个依赖的 ECS 任务...

回答 1 投票 0

如何可视化任意有向无环图?

我正在寻找一种算法来自动可视化大型 DAG。它需要很好地扩展到数百甚至数千个节点和连接(而不变得不可读)。连接应该...

回答 2 投票 0

Dijkstra 具有正权重和循环的有向图算法

如果我有一个带有循环且只有正权重的有向图,并且不使用优先级队列,而是使用队列并继续添加所有子项,包括那些因为我选择而被访问的子项...

回答 1 投票 0

在Airflow中运行docker容器和python脚本

所以我有一个 Scrapy 项目,我可以将其容器化在 Docker 中,以及一个 Jupyter 笔记本(用于正常的数据预处理)。我想使用 Airflow 将它们自动化,但遇到了几个

回答 1 投票 0

Airflow DAG 调度问题:为每月和每周运行传递正确的执行日期

我面临 Airflow 的问题,即我的 DAG 未将正确的执行日期传递给 DAG 中的查询。我有两个 DAG,其中一个计划在每月第一天运行,并且

回答 1 投票 0

在 Airflow DAG 中调用 Google 云函数

我有一个正在运行的谷歌云功能,我正在尝试从 Airflow DAG 调用它。 到目前为止我尝试过的是使用 SimpleHttpOperator: MY_TASK_NAME = SimpleHttpOperator( t...

回答 3 投票 0

如何在Airflow中组合多个DAG

我真的需要知道如何使用 Airflow 让多个 DAG 相互调用(例如 DAG_1 >> DAG_2),类似于它如何使用上游/下游运算符在 DAG 中运行任务。 我需要...

回答 2 投票 0

我们如何在单个 dag 中添加 2 个 sql 查询

export_query: sql_query1 ; 导出查询过滤器:“” 处理模块: 'export_bqtobqtmp_task' 'export_bqtmptogcs_task' 'pre_shell_execution' 'post_shell_execution' 处理_依赖...

回答 1 投票 0

如何在不触发的情况下取消暂停Airflow DAG

我创建了一个 dag 工厂。 我将 dag 切换到取消暂停状态,它们立即开始工作,尽管设置了计划间隔值。尝试通过指定 is_active=False 来覆盖 DagModel。

回答 1 投票 0

气流 DAG 出现错误,>> 不支持操作数类型:“列表”和“列表”。任务的顺序和并行执行

我是 Apache Airflow 和 DAG 的新手。 DAG 中共有 6 个任务(task1、task2、task3、task4、task5、task6)。但在运行 DAG 时,我们收到以下错误。 不支持 DAG

回答 6 投票 0

有没有办法使用R包ggraph(或类似的)绘制到网络节点的定向入口/出口点?

用例:我正在尝试使用优秀的 ggraph 包在 R 中绘制考古“哈里斯矩阵”。哈里斯矩阵是按时间顺序建模的关系有向图

回答 1 投票 0

在 python 中分割 dag 依赖关系

在 Python 中分割 dag 依赖项 我尝试实现一个用于拆分 dag 依赖项的脚本,我的目标是拆分节点依赖项,以便对于具有多个依赖项的每个节点,我

回答 1 投票 0

最新问题
© www.soinside.com 2019 - 2025. All rights reserved.