public abstract class AbstractJournalUpdateTask extends Object implements JournalReaderCallback
Modifier and Type | Field and Description |
---|---|
protected JournalFile |
currentFile |
static String |
FILE_COMPACT_CONTROL |
protected SequentialFileFactory |
fileFactory |
protected JournalFilesRepository |
filesRepository |
protected JournalImpl |
journal |
protected List<JournalFile> |
newDataFiles |
protected long |
nextOrderingID |
protected SequentialFile |
sequentialFile |
Modifier | Constructor and Description |
---|---|
protected |
AbstractJournalUpdateTask(SequentialFileFactory fileFactory,
JournalImpl journal,
JournalFilesRepository filesRepository,
Set<Long> recordsSnapshot,
long nextOrderingID) |
Modifier and Type | Method and Description |
---|---|
protected void |
addToRecordsSnaptshot(long id) |
void |
flush()
Write pending output into file
|
protected ActiveMQBuffer |
getWritingChannel() |
boolean |
lookupRecord(long id) |
protected void |
openFile() |
static SequentialFile |
readControlFile(SequentialFileFactory fileFactory,
List<String> dataFiles,
List<String> newFiles,
List<Pair<String,String>> renameFile) |
static SequentialFile |
writeControlFile(SequentialFileFactory fileFactory,
List<JournalFile> files,
List<JournalFile> newFiles,
List<Pair<String,String>> renames) |
protected void |
writeEncoder(JournalInternalRecord record) |
protected void |
writeEncoder(JournalInternalRecord record,
int txcounter) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
markAsDataFile, onReadAddRecord, onReadAddRecordTX, onReadCommitRecord, onReadDeleteRecord, onReadDeleteRecordTX, onReadPrepareRecord, onReadRollbackRecord, onReadUpdateRecord, onReadUpdateRecordTX
public static final String FILE_COMPACT_CONTROL
protected final JournalImpl journal
protected final SequentialFileFactory fileFactory
protected JournalFile currentFile
protected SequentialFile sequentialFile
protected final JournalFilesRepository filesRepository
protected long nextOrderingID
protected final List<JournalFile> newDataFiles
protected AbstractJournalUpdateTask(SequentialFileFactory fileFactory, JournalImpl journal, JournalFilesRepository filesRepository, Set<Long> recordsSnapshot, long nextOrderingID)
public static SequentialFile writeControlFile(SequentialFileFactory fileFactory, List<JournalFile> files, List<JournalFile> newFiles, List<Pair<String,String>> renames) throws Exception
Exception
public static SequentialFile readControlFile(SequentialFileFactory fileFactory, List<String> dataFiles, List<String> newFiles, List<Pair<String,String>> renameFile) throws Exception
Exception
public boolean lookupRecord(long id)
protected void addToRecordsSnaptshot(long id)
protected ActiveMQBuffer getWritingChannel()
protected void writeEncoder(JournalInternalRecord record) throws Exception
Exception
protected void writeEncoder(JournalInternalRecord record, int txcounter) throws Exception
Exception
Copyright © 2017 JBoss by Red Hat. All rights reserved.