ArrowForeignStorage.h File Reference

#include <arrow/api.h>
#include <memory>
#include <string>
#include "ForeignStorageInterface.h"

Include dependency graph for ArrowForeignStorage.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
void	registerArrowCsvForeignStorage (std::shared_ptr< ForeignStorageInterface > fsi)
void	registerArrowForeignStorage (std::shared_ptr< ForeignStorageInterface > fsi)
void	setArrowTable (std::string name, std::shared_ptr< arrow::Table > table)
void	releaseArrowTable (std::string name)

Function Documentation

void registerArrowCsvForeignStorage

(

std::shared_ptr< ForeignStorageInterface >

fsi

)

Definition at line 1024 of file ArrowForeignStorage.cpp.

Referenced by PersistentStorageMgr::PersistentStorageMgr().

                                                                                {
  fsi->registerPersistentStorageInterface(std::make_unique<ArrowCsvForeignStorage>());
}

Here is the caller graph for this function:

void registerArrowForeignStorage

(

std::shared_ptr< ForeignStorageInterface >

fsi

)

Definition at line 860 of file ArrowForeignStorage.cpp.

Referenced by PersistentStorageMgr::PersistentStorageMgr().

                                                                             {
  fsi->registerPersistentStorageInterface(std::make_unique<ArrowForeignStorage>());
}

Here is the caller graph for this function:

void releaseArrowTable

(

std::string

name

)

Definition at line 856 of file ArrowForeignStorage.cpp.

References ArrowForeignStorage::tables.

Referenced by EmbeddedDatabase::DBEngineImpl::importArrowTable().

                                       {
  ArrowForeignStorage::tables.erase(name);
}

Here is the caller graph for this function:

void setArrowTable	(	std::string	name,
		std::shared_ptr< arrow::Table >	table
	)

Definition at line 852 of file ArrowForeignStorage.cpp.

References setup::name, test_readcsv::table, and ArrowForeignStorage::tables.

Referenced by EmbeddedDatabase::DBEngineImpl::importArrowTable().

                                                                    {
  ArrowForeignStorage::tables[name] = table;
}

Here is the caller graph for this function: