27 const parquet::ColumnDescriptor* parquet_column_descriptor)
30 parquet_column_descriptor) {
31 CHECK(parquet_column_descriptor->logical_type()->is_date());
35 int8_t* omnisci_data_bytes)
override {
36 const auto& parquet_data_value =
37 reinterpret_cast<const int32_t*
>(parquet_data_bytes)[0];
38 auto& omnisci_data_value =
reinterpret_cast<int64_t*
>(omnisci_data_bytes)[0];
39 omnisci_data_value = parquet_data_value *
kSecsPerDay;
42 void validate(std::shared_ptr<parquet::Statistics> stats,
52 auto [unencoded_stats_min, unencoded_stats_max] =
57 unencoded_stats_min * kSecsPerDay, column_type);
HOST DEVICE EncodingType get_compression() const
void encodeAndCopy(const int8_t *parquet_data_bytes, int8_t *omnisci_data_bytes) override
An AbstractBuffer is a unit of data management for a data manager.
specifies the content in-memory of a row in the column metadata table
static void validateValue(const D &data_value, const SQLTypeInfo &column_type)
std::pair< T, T > getUnencodedStats(std::shared_ptr< parquet::Statistics > stats) const
ParquetDateInSecondsEncoder(Data_Namespace::AbstractBuffer *buffer, const ColumnDescriptor *column_desciptor, const parquet::ColumnDescriptor *parquet_column_descriptor)
void validate(std::shared_ptr< parquet::Statistics > stats, const SQLTypeInfo &column_type) const override