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 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-2012 Apache Software Foundation. All Rights Reserved.