Skip to content

Commit a159aac

Browse files
committed
[Feature][transform-v2] sql transform support multi_if function
1 parent e452320 commit a159aac

File tree

1 file changed

+9
-1
lines changed
  • seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform

1 file changed

+9
-1
lines changed

Diff for: seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-e2e-part-2/src/test/resources/sql_transform/func_multi_if.conf

+9-1
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,8 @@ transform {
5252
score,
5353
name,
5454
MULTI_IF(age < 18, 'Minor', age < 30, 'Young Adult', age < 40, 'Adult', 'Senior') as age_category,
55-
MULTI_IF(score >= 90, 'A', score >= 80, 'B', score >= 70, 'C', score >= 60, 'D', 'F') as grade
55+
MULTI_IF(score >= 90, 'A', score >= 80, 'B', score >= 70, 'C', score >= 60, 'D', 'F') as grade,
56+
MULTI_IF(score >= 90, 'excellent', 'pass') as grade_category,
5657
FROM fake
5758
"""
5859
}
@@ -93,6 +94,13 @@ sink {
9394
field_value = [
9495
{equals_to = "B"}
9596
]
97+
},
98+
{
99+
field_name = "grade_category"
100+
field_type = "string"
101+
field_value = [
102+
{equals_to = "pass"}
103+
]
96104
}
97105
]
98106
}

0 commit comments

Comments
 (0)