OmniSciDB
a5dc49c757
|
#include <InternalLogsDataWrapper.h>
Public Member Functions | |
InternalLogsDataWrapper () | |
InternalLogsDataWrapper (const int db_id, const ForeignTable *foreign_table) | |
InternalLogsDataWrapper (const int db_id, const ForeignTable *foreign_table, const UserMapping *user_mapping) | |
Public Member Functions inherited from foreign_storage::RegexParserDataWrapper | |
RegexParserDataWrapper () | |
RegexParserDataWrapper (const int db_id, const ForeignTable *foreign_table) | |
RegexParserDataWrapper (const int db_id, const ForeignTable *foreign_table, const UserMapping *user_mapping, const bool disable_cache=false) | |
void | validateTableOptions (const ForeignTable *foreign_table) const override |
const std::set < std::string_view > & | getSupportedTableOptions () const override |
Public Member Functions inherited from foreign_storage::AbstractTextFileDataWrapper | |
AbstractTextFileDataWrapper () | |
AbstractTextFileDataWrapper (const int db_id, const ForeignTable *foreign_table) | |
AbstractTextFileDataWrapper (const int db_id, const ForeignTable *foreign_table, const UserMapping *user_mapping, const bool disable_cache) | |
void | populateChunkMetadata (ChunkMetadataVector &chunk_metadata_vector) override |
void | populateChunkBuffers (const ChunkToBufferMap &required_buffers, const ChunkToBufferMap &optional_buffers, AbstractBuffer *delete_buffer) override |
std::string | getSerializedDataWrapper () const override |
void | restoreDataWrapperInternals (const std::string &file_path, const ChunkMetadataVector &chunk_metadata) override |
bool | isRestored () const override |
ParallelismLevel | getCachedParallelismLevel () const override |
ParallelismLevel | getNonCachedParallelismLevel () const override |
bool | isLazyFragmentFetchingEnabled () const override |
Public Member Functions inherited from foreign_storage::AbstractFileStorageDataWrapper | |
AbstractFileStorageDataWrapper () | |
void | validateServerOptions (const ForeignServer *foreign_server) const override |
void | validateUserMappingOptions (const UserMapping *user_mapping, const ForeignServer *foreign_server) const override |
const std::set < std::string_view > & | getSupportedUserMappingOptions () const override |
const std::set< std::string > | getAlterableTableOptions () const override |
Public Member Functions inherited from foreign_storage::ForeignDataWrapper | |
ForeignDataWrapper ()=default | |
virtual | ~ForeignDataWrapper ()=default |
virtual void | validateSchema (const std::list< ColumnDescriptor > &columns) const |
Protected Member Functions | |
const TextFileBufferParser & | getFileBufferParser () const override |
std::optional< size_t > | getMaxFileCount () const override |
Protected Member Functions inherited from foreign_storage::RegexParserDataWrapper | |
const TextFileBufferParser & | getFileBufferParser () const override |
Private Attributes | |
const LogFileBufferParser | log_file_buffer_parser_ |
Additional Inherited Members | |
Public Types inherited from foreign_storage::ForeignDataWrapper | |
enum | ParallelismLevel { NONE, INTRA_FRAGMENT, INTER_FRAGMENT } |
Static Public Member Functions inherited from foreign_storage::AbstractFileStorageDataWrapper | |
static shared::FilePathOptions | getFilePathOptions (const ForeignTable *foreign_table) |
Static Public Attributes inherited from foreign_storage::AbstractFileStorageDataWrapper | |
static const std::string | STORAGE_TYPE_KEY = "STORAGE_TYPE" |
static const std::string | BASE_PATH_KEY = "BASE_PATH" |
static const std::string | FILE_PATH_KEY = "FILE_PATH" |
static const std::string | REGEX_PATH_FILTER_KEY = "REGEX_PATH_FILTER" |
static const std::string | LOCAL_FILE_STORAGE_TYPE = "LOCAL_FILE" |
static const std::string | S3_STORAGE_TYPE = "AWS_S3" |
static const std::string | FILE_SORT_ORDER_BY_KEY = shared::FILE_SORT_ORDER_BY_KEY |
static const std::string | FILE_SORT_REGEX_KEY = shared::FILE_SORT_REGEX_KEY |
static const std::string | ALLOW_FILE_ROLL_OFF_KEY = "ALLOW_FILE_ROLL_OFF" |
static const std::string | THREADS_KEY = "THREADS" |
static const std::array < std::string, 1 > | supported_storage_types |
Static Protected Member Functions inherited from foreign_storage::AbstractFileStorageDataWrapper | |
static std::string | getFullFilePath (const ForeignTable *foreign_table) |
Returns the path to the source file/dir of the table. Depending on options this may result from a concatenation of server and table path options. More... | |
static bool | allowFileRollOff (const ForeignTable *foreign_table) |
Definition at line 23 of file InternalLogsDataWrapper.h.
foreign_storage::InternalLogsDataWrapper::InternalLogsDataWrapper | ( | ) |
Definition at line 22 of file InternalLogsDataWrapper.cpp.
foreign_storage::InternalLogsDataWrapper::InternalLogsDataWrapper | ( | const int | db_id, |
const ForeignTable * | foreign_table | ||
) |
Definition at line 25 of file InternalLogsDataWrapper.cpp.
foreign_storage::InternalLogsDataWrapper::InternalLogsDataWrapper | ( | const int | db_id, |
const ForeignTable * | foreign_table, | ||
const UserMapping * | user_mapping | ||
) |
Definition at line 30 of file InternalLogsDataWrapper.cpp.
|
overrideprotectedvirtual |
Implements foreign_storage::AbstractTextFileDataWrapper.
Definition at line 36 of file InternalLogsDataWrapper.cpp.
References log_file_buffer_parser_.
|
overrideprotectedvirtual |
Reimplemented from foreign_storage::AbstractTextFileDataWrapper.
Definition at line 40 of file InternalLogsDataWrapper.cpp.
References g_logs_system_tables_max_files_count.
|
private |
Definition at line 38 of file InternalLogsDataWrapper.h.
Referenced by getFileBufferParser().