BAEL-3086 - Clean up

This commit is contained in:
Norberto Ritzmann Jr 2019-11-22 10:21:10 +01:00
parent 3f7b103ae8
commit 1061c0e582
3 changed files with 3 additions and 3 deletions

View File

@ -42,7 +42,7 @@ public class GraphExperiments {
private void doGraphFrameAlgorithms(GraphFrame graph) {
graph.pageRank().maxIter(20).resetProbability(0.0001).run().vertices().show();
graph.pageRank().maxIter(20).resetProbability(0.15).run().vertices().show();
graph.connectedComponents().run().show();

View File

@ -27,7 +27,7 @@ public class GraphLoader {
Path temp = Files.createTempDirectory("sparkGraphFrames");
SparkSession session = SparkSession.builder()
.appName("SparkGraphFrameSample")
.config("spark.sql.warehouse.dir", temp.toString())//"/file:C:/temp"
.config("spark.sql.warehouse.dir", temp.toString())
.sparkContext(getSparkContext().sc())
.master("local[*]")
.getOrCreate();

View File

@ -22,6 +22,6 @@ public class User implements Serializable {
@Override
public String toString() {
return "struct<" + id + "," + name + ">";
return "<" + id + "," + name + ">";
}
}