float support

parquet/parquet.cc

@@ -178,6 +178,7 @@ static int parquetColumn(
         sqlite3_result_int(ctx, rv);
         break;
       }
+      case parquet::Type::FLOAT:
       case parquet::Type::DOUBLE:
       {
         double rv = cursor->getDouble(col);
@@ -199,7 +200,6 @@ static int parquetColumn(
         sqlite3_result_int64(ctx, rv);
         break;
       }
-      case parquet::Type::FLOAT:
       case parquet::Type::FIXED_LEN_BYTE_ARRAY:
       default:
         // Should be impossible to get here as we should have forbidden this at

parquet/parquet_cursor.cc

@@ -86,6 +86,17 @@ void ParquetCursor::ensureColumn(int col) {
         }
         break;
       }
+      case parquet::Type::FLOAT:
+      {
+        parquet::FloatScanner* s = (parquet::FloatScanner*)scanners[col].get();
+        float rv = 0;
+        if(s->NextValue(&rv, &wasNull)) {
+          colDoubleValues[col] = rv;
+        } else {
+          throw std::invalid_argument("unexpectedly lacking a next value");
+        }
+        break;
+      }
       case parquet::Type::DOUBLE:
       {
         parquet::DoubleScanner* s = (parquet::DoubleScanner*)scanners[col].get();
@@ -157,7 +168,6 @@ void ParquetCursor::ensureColumn(int col) {
         }
         break;
       }
-      case parquet::Type::FLOAT:
       case parquet::Type::FIXED_LEN_BYTE_ARRAY:
       default:
         // Should be impossible to get here as we should have forbidden this at

parquet/parquet_cursor.h

@@ -41,14 +41,6 @@ public:
   long getInt64(int col);
   double getDouble(int col);
   parquet::ByteArray* getByteArray(int col);
-
-  /*
-  sqlite3_result_double()
-  sqlite3_result_int()
-  sqlite3_result_int64()
-  sqlite3_result_null()
-  sqlite3_result_text()
-  */
 };
 
 #endif