59 lines
1.4 KiB
C++
59 lines
1.4 KiB
C++
#ifndef PARQUET_CURSOR_H
|
|
#define PARQUET_CURSOR_H
|
|
|
|
#include "parquet_filter.h"
|
|
#include "parquet_table.h"
|
|
#include "parquet/api/reader.h"
|
|
|
|
class ParquetCursor {
|
|
|
|
ParquetTable* table;
|
|
std::unique_ptr<parquet::ParquetFileReader> reader;
|
|
std::unique_ptr<parquet::RowGroupMetaData> rowGroupMetadata;
|
|
std::shared_ptr<parquet::RowGroupReader> rowGroup;
|
|
std::vector<std::shared_ptr<parquet::Scanner>> scanners;
|
|
std::vector<parquet::Type::type> types;
|
|
std::vector<parquet::LogicalType::type> logicalTypes;
|
|
|
|
std::vector<int> colRows;
|
|
std::vector<bool> colNulls;
|
|
std::vector<uintptr_t> colIntValues;
|
|
std::vector<double> colDoubleValues;
|
|
std::vector<parquet::ByteArray> colByteArrayValues;
|
|
|
|
int rowId;
|
|
int rowGroupId;
|
|
int rowGroupStartRowId;
|
|
int numRows;
|
|
int numRowGroups;
|
|
int rowsLeftInRowGroup;
|
|
|
|
bool nextRowGroup();
|
|
|
|
std::vector<Constraint> constraints;
|
|
|
|
public:
|
|
ParquetCursor(ParquetTable* table);
|
|
int getRowId();
|
|
bool currentRowSatisfiesFilter();
|
|
bool currentRowGroupSatisfiesFilter();
|
|
void next();
|
|
void close();
|
|
void reset(std::vector<Constraint> constraints);
|
|
bool eof();
|
|
|
|
void ensureColumn(int col);
|
|
bool isNull(int col);
|
|
parquet::Type::type getPhysicalType(int col);
|
|
parquet::LogicalType::type getLogicalType(int col);
|
|
ParquetTable* getTable();
|
|
|
|
int getInt32(int col);
|
|
long getInt64(int col);
|
|
double getDouble(int col);
|
|
parquet::ByteArray* getByteArray(int col);
|
|
};
|
|
|
|
#endif
|
|
|