17 #ifndef DISTRIBUTEDLOADER_H
18 #define DISTRIBUTEDLOADER_H
32 bool load(
const std::vector<std::unique_ptr<import_export::TypedImportBuffer>>&
34 const size_t row_count,
41 #endif // DISTRIBUTEDLOADER_H
Loader(Catalog_Namespace::Catalog &c, const TableDescriptor *t, LoadCallbackType load_callback=nullptr)
bool load(const std::vector< std::unique_ptr< import_export::TypedImportBuffer >> &import_buffers, const size_t row_count, const Catalog_Namespace::SessionInfo *session_info) override
DistributedLoader(const Catalog_Namespace::SessionInfo &parent_session_info, const TableDescriptor *t, LeafAggregator *aggregator)
Catalog_Namespace::Catalog & getCatalog() const