AbstractFileStorageDataWrapper() | foreign_storage::AbstractFileStorageDataWrapper | |
AbstractTextFileDataWrapper() | foreign_storage::AbstractTextFileDataWrapper | |
AbstractTextFileDataWrapper(const int db_id, const ForeignTable *foreign_table) | foreign_storage::AbstractTextFileDataWrapper | |
AbstractTextFileDataWrapper(const int db_id, const ForeignTable *foreign_table, const UserMapping *user_mapping, const bool disable_cache) | foreign_storage::AbstractTextFileDataWrapper | |
AbstractTextFileDataWrapper(const ForeignTable *foreign_table) | foreign_storage::AbstractTextFileDataWrapper | private |
ALLOW_FILE_ROLL_OFF_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
allowFileRollOff(const ForeignTable *foreign_table) | foreign_storage::AbstractFileStorageDataWrapper | protectedstatic |
append_start_offset_ | foreign_storage::AbstractTextFileDataWrapper | private |
BASE_PATH_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
buffer_size_ | foreign_storage::AbstractTextFileDataWrapper | private |
chunk_encoder_buffers_ | foreign_storage::AbstractTextFileDataWrapper | private |
chunk_metadata_map_ | foreign_storage::AbstractTextFileDataWrapper | private |
db_id_ | foreign_storage::AbstractTextFileDataWrapper | private |
disable_cache_ | foreign_storage::AbstractTextFileDataWrapper | private |
FILE_PATH_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
file_reader_ | foreign_storage::AbstractTextFileDataWrapper | private |
FILE_SORT_ORDER_BY_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
FILE_SORT_REGEX_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
foreign_table_ | foreign_storage::AbstractTextFileDataWrapper | private |
ForeignDataWrapper()=default | foreign_storage::ForeignDataWrapper | |
fragment_id_to_file_regions_map_ | foreign_storage::AbstractTextFileDataWrapper | private |
getAlterableTableOptions() const override | foreign_storage::AbstractFileStorageDataWrapper | virtual |
getCachedParallelismLevel() const override | foreign_storage::AbstractTextFileDataWrapper | inlinevirtual |
getFileBufferParser() const =0 | foreign_storage::AbstractTextFileDataWrapper | protectedpure virtual |
getFilePathOptions(const ForeignTable *foreign_table) | foreign_storage::AbstractFileStorageDataWrapper | static |
getFullFilePath(const ForeignTable *foreign_table) | foreign_storage::AbstractFileStorageDataWrapper | protectedstatic |
getMaxFileCount() const | foreign_storage::AbstractTextFileDataWrapper | protectedvirtual |
getNonCachedParallelismLevel() const override | foreign_storage::AbstractTextFileDataWrapper | inlinevirtual |
getSerializedDataWrapper() const override | foreign_storage::AbstractTextFileDataWrapper | virtual |
getSupportedTableOptions() const override | foreign_storage::AbstractFileStorageDataWrapper | virtual |
getSupportedUserMappingOptions() const override | foreign_storage::AbstractFileStorageDataWrapper | virtual |
INTER_FRAGMENT enum value | foreign_storage::ForeignDataWrapper | |
INTRA_FRAGMENT enum value | foreign_storage::ForeignDataWrapper | |
is_file_scan_in_progress_ | foreign_storage::AbstractTextFileDataWrapper | private |
is_first_file_scan_call_ | foreign_storage::AbstractTextFileDataWrapper | private |
is_restored_ | foreign_storage::AbstractTextFileDataWrapper | private |
isLazyFragmentFetchingEnabled() const override | foreign_storage::AbstractTextFileDataWrapper | inlinevirtual |
isRestored() const override | foreign_storage::AbstractTextFileDataWrapper | virtual |
iterative_scan_last_fragment_id_ | foreign_storage::AbstractTextFileDataWrapper | private |
iterativeFileScan(ChunkMetadataVector &chunk_metadata_vector, IterativeFileScanParameters &file_scan_param) | foreign_storage::AbstractTextFileDataWrapper | private |
LOCAL_FILE_STORAGE_TYPE | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
multi_threading_params_ | foreign_storage::AbstractTextFileDataWrapper | private |
NONE enum value | foreign_storage::ForeignDataWrapper | |
num_rows_ | foreign_storage::AbstractTextFileDataWrapper | private |
ParallelismLevel enum name | foreign_storage::ForeignDataWrapper | |
populateChunkBuffers(const ChunkToBufferMap &required_buffers, const ChunkToBufferMap &optional_buffers, AbstractBuffer *delete_buffer) override | foreign_storage::AbstractTextFileDataWrapper | virtual |
populateChunkMapForColumns(const std::set< const ColumnDescriptor * > &columns, const int fragment_id, const ChunkToBufferMap &buffers, std::map< int, Chunk_NS::Chunk > &column_id_to_chunk_map) | foreign_storage::AbstractTextFileDataWrapper | private |
populateChunkMetadata(ChunkMetadataVector &chunk_metadata_vector) override | foreign_storage::AbstractTextFileDataWrapper | virtual |
populateChunks(std::map< int, Chunk_NS::Chunk > &column_id_to_chunk_map, int fragment_id, AbstractBuffer *delete_buffer) | foreign_storage::AbstractTextFileDataWrapper | private |
REGEX_PATH_FILTER_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
residual_buffer_ | foreign_storage::AbstractTextFileDataWrapper | private |
restoreDataWrapperInternals(const std::string &file_path, const ChunkMetadataVector &chunk_metadata) override | foreign_storage::AbstractTextFileDataWrapper | virtual |
S3_STORAGE_TYPE | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
STORAGE_TYPE_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
supported_storage_types | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
thread_count_ | foreign_storage::AbstractTextFileDataWrapper | private |
THREADS_KEY | foreign_storage::AbstractFileStorageDataWrapper | inlinestatic |
updateMetadata(std::map< int, Chunk_NS::Chunk > &column_id_to_chunk_map, int fragment_id) | foreign_storage::AbstractTextFileDataWrapper | private |
updateRolledOffChunks(const std::set< std::string > &rolled_off_files, const std::map< int32_t, const ColumnDescriptor * > &column_by_id) | foreign_storage::AbstractTextFileDataWrapper | private |
user_mapping_ | foreign_storage::AbstractTextFileDataWrapper | 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 |