OmniSciDB
85c2d10cdc
|
#include <ParquetDateInSecondsEncoder.h>
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 |
void | validate (std::shared_ptr< parquet::Statistics > stats, const SQLTypeInfo &column_type) const override |
![]() | |
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 |
std::shared_ptr< ChunkMetadata > | getRowGroupMetadata (const parquet::RowGroupMetaData *group_metadata, const int parquet_column_index, const SQLTypeInfo &column_type) override |
![]() | |
ParquetInPlaceEncoder (Data_Namespace::AbstractBuffer *buffer, const size_t omnisci_data_type_byte_size, const size_t parquet_data_type_byte_size) | |
![]() | |
ParquetScalarEncoder (Data_Namespace::AbstractBuffer *buffer) | |
![]() | |
ParquetEncoder (Data_Namespace::AbstractBuffer *buffer) | |
virtual | ~ParquetEncoder ()=default |
![]() | |
virtual | ~ParquetMetadataValidator ()=default |
Additional Inherited Members | |
![]() | |
virtual bool | encodingIsIdentityForSameTypes () const |
std::pair< int32_t, int32_t > | getUnencodedStats (std::shared_ptr< parquet::Statistics > stats) const |
![]() | |
static std::shared_ptr < ChunkMetadata > | createMetadata (const SQLTypeInfo &column_type) |
static void | throwNotNullViolation (const std::string &parquet_column_name) |
static void | validateNullCount (const std::string &parquet_column_name, int64_t null_count, const SQLTypeInfo &column_type) |
![]() | |
const size_t | omnisci_data_type_byte_size_ |
![]() | |
Data_Namespace::AbstractBuffer * | buffer_ |
Definition at line 22 of file ParquetDateInSecondsEncoder.h.
|
inline |
|
inlineoverridevirtual |
Implements foreign_storage::ParquetScalarEncoder.
Definition at line 34 of file ParquetDateInSecondsEncoder.h.
References kSecsPerDay.
|
inlineoverridevirtual |
Implements foreign_storage::ParquetMetadataValidator.
Definition at line 42 of file ParquetDateInSecondsEncoder.h.
References CHECK, SQLTypeInfo::get_compression(), foreign_storage::TypedParquetInPlaceEncoder< V, T >::getUnencodedStats(), SQLTypeInfo::is_date(), kENCODING_NONE, kSecsPerDay, and foreign_storage::DateInSecondsBoundsValidator< T >::validateValue().