그래서 노드가 일부 작업을 나타내고 가장자리가 해당 작업 간의 데이터 흐름을 나타내는 방향 그래프를 작성할 수있는 웹 응용 프로그램을 작성합니다. 그래서 가장자리 {u, v}에 대해서, v가하기 전에 실행해야합니다. Click this link to see a sample graph START 노드는 초기 값을 나타내며 출력을 제외한 다른 노드는 지정된대로
을 cogrouped, 어떻게 정확하게는 다음과 같은 작업을 처리하고있다 :이 작업은 rdd2.toDebugString을 관련 val rdd = sc.parallelize(List(1 to 10).flatMap(x=>x).zipWithIndex,3)
.partitionBy(new HashPartitioner(4))
val rdd1 = sc.parall
긍정적으로 가중 된 Directed Acyclic Graph에서 최단 경로를 찾는 문제가 있지만 N 단계의 최대 수 (경로의 가장자리)의 제한이 있습니다. 경로가 있다고 가정합니다. 그래프의 추가 속성은 에지 (i, j)가 그래프에 있으면 모든 에지 (i, k)도 i < k <j에 대한 그래프에 있음을 의미합니다. 나는 그래프의 시작과 끝 사이의 최단 경로
this 질문에 영감을 받아 JSON에서 DAG를 표현하려고합니다. 내 경우에는 일부 데이터가 들어있는 가장자리와 노드가 포함됩니다 (이 예와 같이 문자열이 아님). 나는이 같은 사양의 생각 : 내가 가진 {
"graph": {
"a": ["b", "c"],
"b": ["c"]
"c"
},
"no
독립적으로 완료 할 수있는 여러 개의 업스트림 작업을 완료해야하는 작업이있을 수 있습니까? download_fcr ->process_fcr ->load_fcr download_survey ->process_survey는 ->load_survey create_dashboard이 필요합니다 load_fcr a load_survey를 성공적으로 완료하십시오. '
에 두 노드 사이의 모든 경로를 찾기 나는 다음과 같은 인접리스트 나는 L에서 R 모든 경로를 찾으려면 L | G, B, P
G | P, I
B | I
P | I
I | R
R | \
이있는 DAG 있습니다. 저는 DFS를해야한다는 것을 알고 있습니다. 그리고 이것은 제가 지금까지 가지고있는 것입니다. 내가 찾고 결과를 dfs(G, "L")의
Gremlin/TinkerPop 쿼리 언어를 사용하면 방향성이있는 비순환 그래프의 위상 순서를 계산할 수 있습니까? 예를 들어, I는 다음과 같은 순서, 위상 중 하나를 획득하려는 다음 에지 a -> b, a -> d, b -> c, c -> d, e -> c
와 그래프 주어진 : a, b, e, c, d 또는 a, e, b, c, d 또는 e, a,
나는 apache airflow 1.8을 탐색 중입니다. 나는 DAGs 또는 tasks에 인수를 전달할 수있는 방법이 있습니까? 아니면 backfilling입니까? 여기 은 같은 것입니다 내가 airflow backfill My_DAG -s some_date -e end_date argument_for_t1 argument_for_t2
, 찾고 있어요하
"증가하는 사전 번호에 따라 DAG의 정점을 정렬하면 토폴로지 정렬이 발생합니다." 분명히 진실한 진술이 아니지만 나는 그것이 왜 그렇게 보이지 않는 것입니다. 그래프가 지시되고 사이클을 가지지 않는다면 우리가 꼭지점을 방문하는 순서가 반드시 위상 적으로 정렬하는 올바른 순서가되어서는 안됩니까?