diff --git a/parquet/parquet_cursor.cc b/parquet/parquet_cursor.cc index 806ae77..52ee438 100644 --- a/parquet/parquet_cursor.cc +++ b/parquet/parquet_cursor.cc @@ -7,6 +7,9 @@ ParquetCursor::ParquetCursor(ParquetTable* table) { } bool ParquetCursor::currentRowGroupSatisfiesRowIdFilter(Constraint& constraint) { + if(constraint.type != Integer) + return true; + int64_t target = constraint.intValue; switch(constraint.op) { case IsNull: