Skip to content

Commit a9d7b65

Browse files
committed
widening conversions for CAST
1 parent c9b7b68 commit a9d7b65

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterPredicateImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ public SerializableFunction<List<Object>, Object> deriveOperation(final SqlKind
5757
case MINUS -> widenToDouble.apply(input.get(0)) - widenToDouble.apply(input.get(1));
5858
case PLUS -> widenToDouble.apply(input.get(0)) + widenToDouble.apply(input.get(1));
5959
// TODO: may need better support for CASTing in the future. See sqlCast() in this file.
60-
case CAST -> ensureComparable.apply(input.get(0));
60+
case CAST -> input.get(0) instanceof Number ? widenToDouble.apply(input.get(0)) : ensureComparable.apply(input.get(0));
6161
case SEARCH -> {
6262
if (input.get(0) instanceof final ImmutableRangeSet range) {
6363
assert input.get(1) instanceof Comparable

0 commit comments

Comments
 (0)