Skip to content

Commit 91376df

Browse files
committed
update transitive_closure
1 parent bb1bc9c commit 91376df

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

graph_computation/transitive_closure.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -4,15 +4,15 @@
44
Author: ZhangHongYu
55
Date: 2022-07-01 22:04:00
66
LastEditors: ZhangHongYu
7-
LastEditTime: 2022-07-02 10:17:32
7+
LastEditTime: 2022-07-02 11:51:50
88
'''
99
from pyspark.sql import SparkSession
1010
n_slices = 2 # Number of Slices
1111

1212
if __name__ == "__main__":
1313
spark = SparkSession\
1414
.builder\
15-
.appName("TransitiveClosure")\
15+
.appName("Transitive Closure")\
1616
.getOrCreate()
1717

1818
paths = spark.sparkContext.parallelize([(1, 2), (1, 3), (2, 3), (3, 1)], n_slices).cache()

0 commit comments

Comments
 (0)