Skip to content

Update scala code #479

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
rjurney merged 19 commits into from
Jan 17, 2025
Merged

Update scala code #479

Changes from 1 commit
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
3ace902
GraphFrame.scala:711
bjornjorgensen Jan 15, 2025
d57b55c
BeliefPropagation.scala
bjornjorgensen Jan 15, 2025
feaaa46
GraphFrame.scala:805
bjornjorgensen Jan 15, 2025
6b14b95
ArraySeq.unsafeWrapArray
bjornjorgensen Jan 15, 2025
1006458
mutable.WrappedArray
bjornjorgensen Jan 15, 2025
66a6b8a
.toSeq
bjornjorgensen Jan 15, 2025
0ba6177
ArraySeq
bjornjorgensen Jan 15, 2025
24dbf51
toIndexedSeq
bjornjorgensen Jan 15, 2025
547ec04
graphs .toIndexedSeq
bjornjorgensen Jan 15, 2025
a4d295a
als_data toIndexedSeq
bjornjorgensen Jan 15, 2025
b9c917f
val vs toIndexedSeq
bjornjorgensen Jan 15, 2025
820e414
scala.jdk.CollectionConverters
bjornjorgensen Jan 15, 2025
1c13baf
graphFrame toIndexedSeq
bjornjorgensen Jan 15, 2025
59b4ba1
Split the column list
bjornjorgensen Jan 15, 2025
1089511
DataFrame.select
bjornjorgensen Jan 15, 2025
4edbaeb
Cols.toSeq
bjornjorgensen Jan 15, 2025
c168064
Added .toSeq before : _*
bjornjorgensen Jan 15, 2025
d3d6340
fix the
bjornjorgensen Jan 15, 2025
003f6ec
remove WrappedArray in graphframe
bjornjorgensen Jan 15, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
val vs toIndexedSeq
  • Loading branch information
@bjornjorgensen
bjornjorgensen committed Jan 15, 2025
commit b9c917f1b83be9df05afb3a6db0fb352640582ff
2 changes: 1 addition & 1 deletion src/main/scala/org/graphframes/examples/Graphs.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -127,7 +127,7 @@ class Graphs private[graphframes] () {
(fields(0).toLong * 2, fields(1).toLong * 2 + 1, fields(2).toDouble)
}
val edges = spark.createDataFrame(data).toDF("src", "dst", "weight")
val vs = data.flatMap(r => r._1 :: r._2 :: Nil).collect().distinct.map(x => Tuple1(x))
val vs = data.flatMap(r => r._1 :: r._2 :: Nil).collect().distinct.map(x => Tuple1(x)).toIndexedSeq
val vertices = spark.createDataFrame(vs).toDF("id")
GraphFrame(vertices, edges)
}
Expand Down