org.apache.kahadb.journal
Class ReadOnlyJournal
java.lang.Object
org.apache.kahadb.journal.Journal
org.apache.kahadb.journal.ReadOnlyJournal
public class ReadOnlyJournal
- extends Journal
An AsyncDataManager that works in read only mode against multiple data directories.
Useful for reading back archived data files.
Fields inherited from class org.apache.kahadb.journal.Journal |
accessorPool, appender, archiveDataLogs, BATCH_CONTROL_RECORD_HEADER, BATCH_CONTROL_RECORD_MAGIC, BATCH_CONTROL_RECORD_SIZE, BATCH_CONTROL_RECORD_TYPE, checkForCorruptionOnStartup, checksum, cleanupTask, dataFiles, DEFAULT_ARCHIVE_DIRECTORY, DEFAULT_CLEANUP_INTERVAL, DEFAULT_DIRECTORY, DEFAULT_FILE_PREFIX, DEFAULT_FILE_SUFFIX, DEFAULT_MAX_FILE_LENGTH, DEFAULT_MAX_WRITE_BATCH_SIZE, directory, directoryArchive, fileByFileMap, fileMap, filePrefix, fileSuffix, inflightWrites, lastAppendLocation, maxFileLength, PREFERED_DIFF, preferedFileLength, RECORD_HEAD_SPACE, started, totalLength, USER_RECORD_TYPE, writeBatchSize |
Methods inherited from class org.apache.kahadb.journal.Journal |
appendedExternally, checkBatchRecord, getCurrentDataFileId, getDirectory, getDirectoryArchive, getDiskSize, getFile, getFileMap, getFilePrefix, getFiles, getFileSuffix, getInflightWrites, getLastAppendLocation, getMaxFileLength, getNextLocation, getNextLocation, getNextLocation, getReplicationTarget, getWriteBatchSize, isArchiveDataLogs, isCheckForCorruptionOnStartup, isChecksum, read, recoveryCheck, removeDataFiles, setArchiveDataLogs, setCheckForCorruptionOnStartup, setChecksum, setDirectory, setDirectoryArchive, setFilePrefix, setFileSuffix, setLastAppendLocation, setMaxFileLength, setReplicationTarget, setWriteBatchSize, toString, update, write, write |
ReadOnlyJournal
public ReadOnlyJournal(ArrayList<File> dirs)
start
public void start()
throws IOException
- Overrides:
start
in class Journal
- Throws:
IOException
close
public void close()
throws IOException
- Overrides:
close
in class Journal
- Throws:
IOException
getFirstLocation
public Location getFirstLocation()
throws IllegalStateException,
IOException
- Throws:
IllegalStateException
IOException
delete
public boolean delete()
throws IOException
- Overrides:
delete
in class Journal
- Throws:
IOException
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.