OmniSciDB  2e3a973ef4
foreign_storage::ParquetDateInSecondsEncoder Class Reference

#include <ParquetDateInSecondsEncoder.h>

+ Inheritance diagram for foreign_storage::ParquetDateInSecondsEncoder:
+ Collaboration diagram for foreign_storage::ParquetDateInSecondsEncoder:

Public Member Functions

 ParquetDateInSecondsEncoder (Data_Namespace::AbstractBuffer *buffer, const ColumnDescriptor *column_desciptor, const parquet::ColumnDescriptor *parquet_column_descriptor)
 
void encodeAndCopy (const int8_t *parquet_data_bytes, int8_t *omnisci_data_bytes) override
 
- Public Member Functions inherited from foreign_storage::TypedParquetInPlaceEncoder< int64_t, int32_t >
 TypedParquetInPlaceEncoder (Data_Namespace::AbstractBuffer *buffer, const ColumnDescriptor *column_desciptor, const parquet::ColumnDescriptor *parquet_column_descriptor)
 
 TypedParquetInPlaceEncoder (Data_Namespace::AbstractBuffer *buffer, const size_t omnisci_data_type_byte_size, const size_t parquet_data_type_byte_size)
 
void appendData (const int16_t *def_levels, const int16_t *rep_levels, const int64_t values_read, const int64_t levels_read, const bool is_last_batch, int8_t *values) override
 
void encodeAndCopyContiguous (const int8_t *parquet_data_bytes, int8_t *omnisci_data_bytes, const size_t num_elements) override
 
void setNull (int8_t *omnisci_data_bytes) override
 
void copy (const int8_t *omnisci_data_bytes_source, int8_t *omnisci_data_bytes_destination) override
 
- Public Member Functions inherited from foreign_storage::ParquetInPlaceEncoder
 ParquetInPlaceEncoder (Data_Namespace::AbstractBuffer *buffer, const size_t omnisci_data_type_byte_size, const size_t parquet_data_type_byte_size)
 
- Public Member Functions inherited from foreign_storage::ParquetScalarEncoder
 ParquetScalarEncoder (Data_Namespace::AbstractBuffer *buffer)
 
- Public Member Functions inherited from foreign_storage::ParquetEncoder
 ParquetEncoder (Data_Namespace::AbstractBuffer *buffer)
 
virtual ~ParquetEncoder ()=default
 

Additional Inherited Members

- Protected Member Functions inherited from foreign_storage::TypedParquetInPlaceEncoder< int64_t, int32_t >
virtual bool encodingIsIdentityForSameTypes () const
 
- Protected Attributes inherited from foreign_storage::ParquetInPlaceEncoder
const size_t omnisci_data_type_byte_size_
 
- Protected Attributes inherited from foreign_storage::ParquetEncoder
Data_Namespace::AbstractBufferbuffer_
 

Detailed Description

Definition at line 23 of file ParquetDateInSecondsEncoder.h.

Constructor & Destructor Documentation

◆ ParquetDateInSecondsEncoder()

foreign_storage::ParquetDateInSecondsEncoder::ParquetDateInSecondsEncoder ( Data_Namespace::AbstractBuffer buffer,
const ColumnDescriptor column_desciptor,
const parquet::ColumnDescriptor *  parquet_column_descriptor 
)
inline

Definition at line 25 of file ParquetDateInSecondsEncoder.h.

References CHECK.

28  : TypedParquetInPlaceEncoder<int64_t, int32_t>(buffer,
29  column_desciptor,
30  parquet_column_descriptor) {
31  CHECK(parquet_column_descriptor->logical_type()->is_date());
32  }
#define CHECK(condition)
Definition: Logger.h:197

Member Function Documentation

◆ encodeAndCopy()

void foreign_storage::ParquetDateInSecondsEncoder::encodeAndCopy ( const int8_t *  parquet_data_bytes,
int8_t *  omnisci_data_bytes 
)
inlineoverridevirtual

Implements foreign_storage::ParquetScalarEncoder.

Definition at line 34 of file ParquetDateInSecondsEncoder.h.

References kSecsPerDay.

35  {
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;
40  }
static constexpr int64_t kSecsPerDay

The documentation for this class was generated from the following file: