Bug fix

Author: anlowee

presto-clp/src/main/java/com/facebook/presto/plugin/clp/optimization/ClpFilterToKqlConverter.java

@@ -57,6 +57,8 @@
 import static com.facebook.presto.common.type.IntegerType.INTEGER;
 import static com.facebook.presto.common.type.RealType.REAL;
 import static com.facebook.presto.common.type.SmallintType.SMALLINT;
+import static com.facebook.presto.common.type.TimestampType.TIMESTAMP;
+import static com.facebook.presto.common.type.TimestampType.TIMESTAMP_MICROSECONDS;
 import static com.facebook.presto.common.type.TinyintType.TINYINT;
 import static com.facebook.presto.plugin.clp.ClpErrorCode.CLP_PUSHDOWN_UNSUPPORTED_EXPRESSION;
 import static com.facebook.presto.spi.relation.SpecialFormExpression.Form.AND;
@@ -914,6 +916,8 @@ public static boolean isClpCompatibleNumericType(Type type)
                 || type.equals(TINYINT)
                 || type.equals(DOUBLE)
                 || type.equals(REAL)
+                || type.equals(TIMESTAMP)
+                || type.equals(TIMESTAMP_MICROSECONDS)
                 || type instanceof DecimalType;
     }
 

presto-clp/src/main/java/com/facebook/presto/plugin/clp/split/ClpPinotSplitProvider.java

@@ -102,7 +102,9 @@ public List<ClpSplit> listSplits(ClpTableLayoutHandle clpTableLayoutHandle)
                 SplitType splitType = splitPath.endsWith(".clp.zst") ? IR : ARCHIVE;
                 splits.add(new ClpSplit(splitPath, splitType, Optional.empty()));
             }
-            return splits.build();
+            List<ClpSplit> filteredSplits = splits.build();
+            log.debug("Number of filtered splits: %s", filteredSplits.size());
+            return filteredSplits;
         }
         catch (Exception e) {
             log.error(e);