Skip to content

feat: variable length pattern matching #685

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 12 commits into from
Sep 20, 2025
Merged

feat: variable length pattern matching #685

Changes from 1 commit
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
fd5a548
variable length pattern matching
gounnaa Sep 13, 2025
e2980ac
scalafmtAll
gounnaa Sep 13, 2025
0b947f4
fix exhaustive match error
gounnaa Sep 13, 2025
588d8eb
more test cases
gounnaa Sep 14, 2025
8532f9b
to specify the test result type to long
gounnaa Sep 14, 2025
36a1acc
fixed formatting by scalafmtAll to pass Scala CI test
gounnaa Sep 14, 2025
5e7c708
Improve error message
gounnaa Sep 15, 2025
ec12d16
var-length pattern prototype
gounnaa Sep 16, 2025
a121c02
find variable length pattern
gounnaa Sep 17, 2025
8074635
unsupported case handling
gounnaa Sep 18, 2025
2c47bcc
scalafmtAll
gounnaa Sep 18, 2025
5efe0b7
fixed and var length with named edge support
gounnaa Sep 18, 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
to specify the test result type to long
  • Loading branch information
@gounnaa
gounnaa committed Sep 14, 2025
commit 8532f9b56b2e5eef6df645fd2add080f9205d2dc
15 changes: 9 additions & 6 deletions core/src/test/scala/org/graphframes/PatternMatchSuite.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -554,7 +554,10 @@ class PatternMatchSuite extends SparkFunSuite with GraphFrameTestSparkContext {
.select("u.id", "_v1.id", "_v2.id", "v.id")

val res = varEdge.collect().toSet
val expected = Set(Row(0, 1, 2, 0), Row(0, 1, 2, 3), Row(0, 1, 0, 1))
val expected = Set(
Row(0L, 1L, 2L, 0L),
Row(0L, 1L, 2L, 3L),
Row(0L, 1L, 0L, 1L))
compareResultToExpected(res, expected)
}

Expand All @@ -566,11 +569,11 @@ class PatternMatchSuite extends SparkFunSuite with GraphFrameTestSparkContext {

val res = varEdge.collect().toSet
val expected = Set(
Row(0, 1, 2, 0, 1, 0),
Row(0, 1, 0, 1, 0, 1),
Row(0, 1, 2, 0, 1, 2),
Row(0, 1, 0, 1, 2, 0),
Row(0, 1, 0, 1, 2, 3))
Row(0L, 1L, 2L, 0L, 1L, 0L),
Row(0L, 1L, 0L, 1L, 0L, 1L),
Row(0L, 1L, 2L, 0L, 1L, 2L),
Row(0L, 1L, 0L, 1L, 2L, 0L),
Row(0L, 1L, 0L, 1L, 2L, 3L))
compareResultToExpected(res, expected)
}

Expand Down
Loading