AbstractFileStorageDataWrapper() | foreign_storage::AbstractFileStorageDataWrapper | |
addNewFile(const std::string &file_path) | foreign_storage::ParquetDataWrapper | private |
addNewFragment(int row_group, const std::string &file_path) | foreign_storage::ParquetDataWrapper | private |
ALLOW_FILE_ROLL_OFF_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
allowFileRollOff(const ForeignTable *foreign_table) | foreign_storage::AbstractFileStorageDataWrapper | protectedstatic |
BASE_PATH_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
chunk_metadata_map_ | foreign_storage::ParquetDataWrapper | private |
db_id_ | foreign_storage::ParquetDataWrapper | private |
delete_buffer_mutex_ | foreign_storage::ParquetDataWrapper | private |
do_metadata_stats_validation_ | foreign_storage::ParquetDataWrapper | private |
fetchChunkMetadata() | foreign_storage::ParquetDataWrapper | private |
FILE_PATH_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
file_reader_cache_ | foreign_storage::ParquetDataWrapper | private |
FILE_SORT_ORDER_BY_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
FILE_SORT_REGEX_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
file_system_ | foreign_storage::ParquetDataWrapper | private |
finalizeFragmentMap() | foreign_storage::ParquetDataWrapper | private |
foreign_table_ | foreign_storage::ParquetDataWrapper | private |
ForeignDataWrapper()=default | foreign_storage::ForeignDataWrapper | |
fragment_to_row_group_interval_map_ | foreign_storage::ParquetDataWrapper | private |
getAllFilePaths() | foreign_storage::ParquetDataWrapper | private |
getAlterableTableOptions() const override | foreign_storage::AbstractFileStorageDataWrapper | virtual |
getCachedParallelismLevel() const override | foreign_storage::ParquetDataWrapper | inlinevirtual |
getColumnsToInitialize(const Interval< ColumnType > &column_interval) | foreign_storage::ParquetDataWrapper | private |
getDataPreview(const size_t num_rows) | foreign_storage::ParquetDataWrapper | |
getFilePathOptions(const ForeignTable *foreign_table) | foreign_storage::AbstractFileStorageDataWrapper | static |
getFullFilePath(const ForeignTable *foreign_table) | foreign_storage::AbstractFileStorageDataWrapper | protectedstatic |
getNonCachedParallelismLevel() const override | foreign_storage::ParquetDataWrapper | inlinevirtual |
getOrderedProcessedFilePaths() | foreign_storage::ParquetDataWrapper | private |
getRowGroupMetadataForFilePaths(const std::vector< std::string > &file_paths) const | foreign_storage::ParquetDataWrapper | private |
getRowGroupMetadataMap(const std::vector< std::string > &file_paths) const | foreign_storage::ParquetDataWrapper | private |
getSerializedDataWrapper() const override | foreign_storage::ParquetDataWrapper | virtual |
getSupportedTableOptions() const override | foreign_storage::AbstractFileStorageDataWrapper | virtual |
getSupportedUserMappingOptions() const override | foreign_storage::AbstractFileStorageDataWrapper | virtual |
initializeChunkBuffers(const int fragment_index, const Interval< ColumnType > &column_interval, const ChunkToBufferMap &required_buffers, const bool reserve_buffers_and_set_stats=false) | foreign_storage::ParquetDataWrapper | private |
INTER_FRAGMENT enum value | foreign_storage::ForeignDataWrapper | |
INTRA_FRAGMENT enum value | foreign_storage::ForeignDataWrapper | |
is_restored_ | foreign_storage::ParquetDataWrapper | private |
isLazyFragmentFetchingEnabled() const | foreign_storage::ForeignDataWrapper | inlinevirtual |
isNewFile(const std::string &file_path) const | foreign_storage::ParquetDataWrapper | private |
isRestored() const override | foreign_storage::ParquetDataWrapper | virtual |
last_file_row_count_ | foreign_storage::ParquetDataWrapper | private |
last_fragment_index_ | foreign_storage::ParquetDataWrapper | private |
last_fragment_row_count_ | foreign_storage::ParquetDataWrapper | private |
last_row_group_ | foreign_storage::ParquetDataWrapper | private |
loadBuffersUsingLazyParquetChunkLoader(const int logical_column_id, const int fragment_id, const ChunkToBufferMap &required_buffers, AbstractBuffer *delete_buffer) | foreign_storage::ParquetDataWrapper | private |
LOCAL_FILE_STORAGE_TYPE | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
metadataScanFiles(const std::vector< std::string > &file_paths) | foreign_storage::ParquetDataWrapper | private |
metadataScanRowGroupIntervals(const std::vector< RowGroupInterval > &row_group_intervals) | foreign_storage::ParquetDataWrapper | private |
metadataScanRowGroupMetadata(const std::list< RowGroupMetadata > &row_group_metadata) | foreign_storage::ParquetDataWrapper | private |
moveToNextFragment(size_t new_rows_count) const | foreign_storage::ParquetDataWrapper | private |
NONE enum value | foreign_storage::ForeignDataWrapper | |
ParallelismLevel enum name | foreign_storage::ForeignDataWrapper | |
ParquetDataWrapper() | foreign_storage::ParquetDataWrapper | |
ParquetDataWrapper(const int db_id, const ForeignTable *foreign_table, const bool do_metadata_stats_validation=true) | foreign_storage::ParquetDataWrapper | |
ParquetDataWrapper(const ForeignTable *foreign_table, std::shared_ptr< arrow::fs::FileSystem > file_system) | foreign_storage::ParquetDataWrapper | |
populateChunkBuffers(const ChunkToBufferMap &required_buffers, const ChunkToBufferMap &optional_buffers, AbstractBuffer *delete_buffer) override | foreign_storage::ParquetDataWrapper | virtual |
populateChunkMetadata(ChunkMetadataVector &chunk_metadata_vector) override | foreign_storage::ParquetDataWrapper | virtual |
REGEX_PATH_FILTER_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
removeMetadataForLastFile(const std::string &last_file_path) | foreign_storage::ParquetDataWrapper | private |
resetParquetMetadata() | foreign_storage::ParquetDataWrapper | private |
restoreDataWrapperInternals(const std::string &file_path, const ChunkMetadataVector &chunk_metadata_vector) override | foreign_storage::ParquetDataWrapper | virtual |
S3_STORAGE_TYPE | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
schema_ | foreign_storage::ParquetDataWrapper | private |
setLastFileRowCount(const std::string &file_path) | foreign_storage::ParquetDataWrapper | private |
STORAGE_TYPE_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
supported_storage_types | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
THREADS_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
total_row_count_ | foreign_storage::ParquetDataWrapper | private |
updateChunkMetadataForFragment(const Interval< ColumnType > &column_interval, const std::list< std::shared_ptr< ChunkMetadata >> &column_chunk_metadata, int32_t fragment_id) | foreign_storage::ParquetDataWrapper | private |
updateMetadataForRolledOffFiles(const std::set< std::string > &rolled_off_files) | foreign_storage::ParquetDataWrapper | private |
validateSchema(const std::list< ColumnDescriptor > &columns) const | foreign_storage::ForeignDataWrapper | inlinevirtual |
validateServerOptions(const ForeignServer *foreign_server) const override | foreign_storage::AbstractFileStorageDataWrapper | virtual |
validateTableOptions(const ForeignTable *foreign_table) const override | foreign_storage::AbstractFileStorageDataWrapper | virtual |
validateUserMappingOptions(const UserMapping *user_mapping, const ForeignServer *foreign_server) const override | foreign_storage::AbstractFileStorageDataWrapper | virtual |
~ForeignDataWrapper()=default | foreign_storage::ForeignDataWrapper | virtual |