setop
/
sqlite-parquet-vtable
mirror of https://github.com/cldellow/sqlite-parquet-vtable.git
1
0
Fork 0
Code Releases Activity

Add long_t to be used in place of long long. Alias to int64_t if it works.

This commit is contained in:
Mikko Harju 2019-11-22 17:14:18 +02:00
parent 96405b77dc
commit 83d80910f3
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
parquet/parquet_cursor.cc
View File

@ -1,5 +1,7 @@
#include "parquet_cursor.h" #include "parquet_cursor.h"
typedef int64_t long_t;
ParquetCursor::ParquetCursor(ParquetTable* table): table(table) { ParquetCursor::ParquetCursor(ParquetTable* table): table(table) {
reader = NULL; reader = NULL;
reset(std::vector<Constraint>()); reset(std::vector<Constraint>());
@ -775,7 +777,7 @@ void ParquetCursor::ensureColumn(int col) {
case parquet::Type::INT64: case parquet::Type::INT64:
{ {
parquet::Int64Scanner* s = (parquet::Int64Scanner*)scanners[col].get(); parquet::Int64Scanner* s = (parquet::Int64Scanner*)scanners[col].get();
long long rv = 0; long_t rv = 0;
s->NextValue(&rv, &wasNull); s->NextValue(&rv, &wasNull);
break; break;
} }
@ -859,7 +861,7 @@ void ParquetCursor::ensureColumn(int col) {
case parquet::Type::INT64: case parquet::Type::INT64:
{ {
parquet::Int64Scanner* s = (parquet::Int64Scanner*)scanners[col].get(); parquet::Int64Scanner* s = (parquet::Int64Scanner*)scanners[col].get();
long long rv = 0; long_t rv = 0;
hadValue = s->NextValue(&rv, &wasNull); hadValue = s->NextValue(&rv, &wasNull);
colIntValues[col] = rv; colIntValues[col] = rv;
break; break;