33 vector<string> dataTempPaths,
57 vector<string> dataPaths;
58 int numDataPaths = dataTempPaths.size();
62 for (i = 0; i < numDataPaths; i++) {
64 dataPaths.push_back(dataPath);
66 file = make_shared<PartitionedFile>(
83 sprintf(buffer,
"%s/%d_%s", tempPath.c_str(),
setId, setName.c_str());
84 return string(buffer);
shared_ptr< PageCache > PageCachePtr
void setFile(PartitionedFilePtr file)
TempSet(SetID setId, string setName, string metaTempPath, vector< string > dataTempPaths, SharedMemPtr shm, PageCachePtr cache, pdb::PDBLoggerPtr logger, LocalityType localityType=ShuffleData, LocalitySetReplacementPolicy policy=MRU, OperationType operation=Write, DurabilityType durability=TryCache, PersistenceType persistence=Transient, size_t pageSize=DEFAULT_PAGE_SIZE)
string encodePath(string tempPath, string setName)
LocalitySetReplacementPolicy
shared_ptr< PartitionedFile > PartitionedFilePtr
shared_ptr< SharedMem > SharedMemPtr
std::shared_ptr< PDBLogger > PDBLoggerPtr
PartitionedFilePtr getFile()