Skip to content

Commit 602ed14

Browse files
committed
[flink]support more partition type
1 parent 9489f6a commit 602ed14

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/FlinkTableSource.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -541,7 +541,7 @@ && hasPrimaryKey()
541541
}
542542
// Convert literals in the predicate to string using
543543
// PartitionUtils.convertValueOfType
544-
p = convertPredicateLiteralsToString(p);
544+
p = stringifyPredicate(p);
545545
converted.add(p);
546546
} else {
547547
remainingFilters.add(filter);
@@ -684,7 +684,7 @@ public int[] getPartitionKeyIndexes() {
684684
* PartitionUtils.convertValueOfType. This is necessary because partition metadata is stored as
685685
* string.
686686
*/
687-
private Predicate convertPredicateLiteralsToString(Predicate predicate) {
687+
private Predicate stringifyPredicate(Predicate predicate) {
688688
if (predicate instanceof LeafPredicate) {
689689
// Convert literals to string using PartitionUtils.convertValueOfType
690690
List<Object> convertedLiterals = new ArrayList<>();

0 commit comments

Comments
 (0)