File tree Expand file tree Collapse file tree 3 files changed +3
-3
lines changed
apache-spark/src/main/java/com/baeldung/graphframes Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -42,7 +42,7 @@ private void doGraphFrameOperations(GraphFrame graph) {
42
42
43
43
private void doGraphFrameAlgorithms (GraphFrame graph ) {
44
44
45
- graph .pageRank ().maxIter (20 ).resetProbability (0.0001 ).run ().vertices ().show ();
45
+ graph .pageRank ().maxIter (20 ).resetProbability (0.15 ).run ().vertices ().show ();
46
46
47
47
graph .connectedComponents ().run ().show ();
48
48
Original file line number Diff line number Diff line change @@ -27,7 +27,7 @@ public GraphFrame getGraphFrameUserRelationship() throws IOException {
27
27
Path temp = Files .createTempDirectory ("sparkGraphFrames" );
28
28
SparkSession session = SparkSession .builder ()
29
29
.appName ("SparkGraphFrameSample" )
30
- .config ("spark.sql.warehouse.dir" , temp .toString ())//"/file:C:/temp"
30
+ .config ("spark.sql.warehouse.dir" , temp .toString ())
31
31
.sparkContext (getSparkContext ().sc ())
32
32
.master ("local[*]" )
33
33
.getOrCreate ();
Original file line number Diff line number Diff line change @@ -22,6 +22,6 @@ public String getName() {
22
22
23
23
@ Override
24
24
public String toString () {
25
- return "struct <" + id + "," + name + ">" ;
25
+ return "<" + id + "," + name + ">" ;
26
26
}
27
27
}
You can’t perform that action at this time.
0 commit comments