public class ReadOnlyAsyncDataManager extends AsyncDataManager
accessorPool, appender, archiveDataLogs, cleanupTask, CONTROL_RECORD_MAX_LENGTH, controlFile, currentWriteFile, DATA_ITEM_TYPE, DEFAULT_ARCHIVE_DIRECTORY, DEFAULT_CLEANUP_INTERVAL, DEFAULT_DIRECTORY, DEFAULT_FILE_PREFIX, DEFAULT_MAX_FILE_LENGTH, directory, directoryArchive, fileByFileMap, fileMap, filePrefix, inflightWrites, ITEM_FOOT_SPACE, ITEM_HEAD_EOR, ITEM_HEAD_FOOT_SPACE, ITEM_HEAD_OFFSET_TO_SOR, ITEM_HEAD_RESERVED_SPACE, ITEM_HEAD_SOR, ITEM_HEAD_SPACE, lastAppendLocation, mark, maxFileLength, PREFERED_DIFF, preferedFileLength, REDO_ITEM_TYPE, scheduler, started, storeSize, useNio
Constructor and Description |
---|
ReadOnlyAsyncDataManager(ArrayList<File> dirs) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
delete() |
Location |
getFirstLocation() |
void |
start() |
addInterestInFile, consolidateDataFiles, consolidateDataFilesNotIn, consolidateDataFilesNotIn, getCurrentDataFileId, getDirectory, getDirectoryArchive, getDiskSize, getDiskSizeUntil, getFilePrefix, getFiles, getInflightWrites, getLastAppendLocation, getMark, getMaxFileLength, getNextLocation, getNextLocation, getNextLocation, isArchiveDataLogs, isUseNio, lock, read, recoveryCheck, removeInterestInFile, removeLocation, setArchiveDataLogs, setDirectory, setDirectoryArchive, setFilePrefix, setLastAppendLocation, setMark, setMaxFileLength, setUseNio, storeState, toString, unmarshallState, update, write, write, write
public ReadOnlyAsyncDataManager(ArrayList<File> dirs)
public void start() throws IOException
start
in class AsyncDataManager
IOException
public void close() throws IOException
close
in class AsyncDataManager
IOException
public Location getFirstLocation() throws IllegalStateException, IOException
IllegalStateException
IOException
public boolean delete() throws IOException
delete
in class AsyncDataManager
IOException
Copyright © 2005–2017. All rights reserved.