Modifier and Type | Method and Description |
---|---|
boolean |
LeafPage.add(DataRecordIdentifier dataRecordIdentifier,
IDataBlock dataBlock) |
boolean |
NonTerminalPage.add(ILeafPage existingLeftILeafPage,
ILeafPage newRightILeafPage) |
boolean |
NonTerminalPage.add(INonTerminalPage leftSonNonTerminalPage,
DataRecordIdentifier middleKey,
INonTerminalPage rightSonNonTerminalPage) |
static byte |
DataBlockPage.bitsForLength(int length) |
void |
HeaderPage.decrementNumberOfDataRecord() |
byte[] |
IDataBlock.getData() |
byte[] |
DataBlock.getData() |
byte[] |
DataBlockPage.getData(int indexInDataBlockPage) |
int |
NonTerminalPage.getInParentIndex() |
int |
LeafPage.getInParentIndex() |
int |
IPageRecordable.getInParentIndex() |
int |
INonTerminalPage.getInParentIndex() |
int |
HeaderPage.getInParentIndex() |
int |
FreePage.getInParentIndex() |
int |
DataBlockPage.getInParentIndex() |
long |
HeaderPage.getNewDataRecordIdentifier() |
long |
IDataBlock.getNextFreeDataBlockPositionOfFree()
make sense to be call only if this is a free data block
|
long |
DataBlock.getNextFreeDataBlockPositionOfFree() |
long |
DataBlockPage.getNextFreeDataBlockPositionOfFree(int indexInDataBlockPage) |
IPageRecord |
IPageRecordable.getPageRecord() |
PageRecord |
HeaderPage.getPageRecord() |
IPageRecordable |
IPageRecordable.getParentPage() |
IPageRecordable |
HeaderPage.getParentPage() |
IPageRecordable |
FreePage.getParentPage() |
IPageRecordable |
DataBlockPage.getParentPage() |
long |
PageRecord.getPreviousRecordPositionInFile() |
long |
HeaderPage.getPreviousRecordPositionInFile() |
long |
AbstractElement.getPreviousRecordPositionInFile() |
int |
PageRecord.getRecordSize() |
int |
HeaderPage.getRecordSize() |
void |
HeaderPage.incrementNumberOfDataRecord() |
protected void |
PageRecord.marshallImpl() |
protected void |
HeaderPage.marshallImpl() |
protected byte |
DataBlockPage.readByte() |
protected void |
DataBlockPage.readBytes(byte[] destination) |
protected int |
DataBlockPage.readInteger() |
protected DataRecordIdentifier |
AbstractPageRecord.readKey() |
protected long |
DataBlockPage.readLong() |
protected EnumRecordType |
AbstractPageRecord.readRecordType() |
void |
LeafPage.remove(int index) |
void |
DataBlockPage.setAllFree() |
void |
IDataBlock.setData(byte[] data) |
void |
DataBlock.setData(byte[] data) |
void |
DataBlockPage.setData(int indexInDataBlockPage,
byte[] data) |
void |
LeafPage.setDataBlock(int index,
IDataBlock dataBlock) |
void |
NonTerminalPage.setEntry(int index,
long pagePointer,
DataRecordIdentifier key) |
void |
LeafPage.setEntry(int index,
long pagePointer,
DataRecordIdentifier key) |
void |
HeaderPage.setFileSizeAsNumberOfPage(long fileSizeAsNumberOfPage) |
void |
HeaderPage.setFirstFreeBlock(long firstFreeBlockPosition,
int blockBits) |
void |
HeaderPage.setFreeDataBlockPosition(int bits,
long freeDataBlockPosition) |
boolean |
NonTerminalPage.setKey(int index,
DataRecordIdentifier key)
change key
|
void |
LeafPage.setNext(long next) |
void |
DataBlockPage.setNextFreeDataBlockPositionOfFree(int indexInDataBlockPage,
long nextFreeDataBlockPosition) |
void |
IDataBlock.setNextFreeDataBlockPositionOfFree(long nextFreeDataBlockPosition)
the next free data block position is wrote on data, must be call only if
this is a free data block
|
void |
DataBlock.setNextFreeDataBlockPositionOfFree(long nextFreeDataBlockPosition) |
void |
HeaderPage.setNextFreeDataRecordIdentifier(long value) |
void |
HeaderPage.setPageNumberOfFirstFreePage(long pageNumberOfFirstFreePage) |
void |
IPageRecordable.setPageRecord(IPageRecord pageRecord) |
void |
HeaderPage.setPageRecord(IPageRecord pageRecord) |
void |
PageRecord.setPageRecordable(IPageRecordable pageRecordable) |
void |
IPageRecord.setPageRecordable(IPageRecordable pageRecordable) |
void |
IPageRecordable.setParentPage(IPageRecordable parentPage,
int inParentIndex) |
void |
HeaderPage.setParentPage(IPageRecordable parentPage,
int inParentIndex) |
void |
FreePage.setParentPage(IPageRecordable parentPage,
int inParentIndex) |
void |
DataBlockPage.setParentPage(IPageRecordable parentPage,
int inParentIndex) |
void |
PageRecord.setPreviousRecordPositionInFile(long previousRecordPositionInFile) |
void |
HeaderPage.setRootPagePosition(long rootPagePosition) |
void |
IStateStored.setValueIsChangedValueToSave() |
void |
IPageRecord.setValueIsChangedValueToSave() |
void |
AbstractElement.setValueIsChangedValueToSave() |
INonTerminalPage |
NonTerminalPage.split() |
LeafPage |
LeafPage.split(DataRecordIdentifier dataRecordIdentifier,
IDataBlock dataBlock) |
protected int |
PageRecord.toMarshallSize() |
protected int |
HeaderPage.toMarshallSize() |
int |
NonTerminalPage.tryBalanceOrMerge(DataRecordIdentifier middleKey,
NonTerminalPage rightNonTerminalPage)
update
this#middleKey if do not merge |
int |
LeafPage.tryBalanceOrMerge(LeafPage leafPage) |
protected void |
PageRecord.unmarshallImpl() |
protected void |
HeaderPage.unmarshallImpl() |
void |
NonTerminalPage.updateByteSize() |
void |
LeafPage.updateByteSize() |
void |
IPageRecordable.updateByteSize() |
void |
NonTerminalPage.updateByteSizeAcceptBigger() |
protected void |
PageRecord.valueChangedAction() |
protected void |
HeaderPage.valueChangedAction() |
protected void |
AbstractPageRecord.writeByteRecordType(EnumRecordType recordType) |
protected void |
DataBlockPage.writeBytes(byte[] dataByteArray) |
protected void |
DataBlockPage.writeInteger(int value) |
protected void |
AbstractPageRecord.writeKey(DataRecordIdentifier dataRecordIdentifier) |
protected void |
DataBlockPage.writeLong(long value) |
Constructor and Description |
---|
NonTerminalPage(int numberOfKeyEntries,
DataRecordIdentifier[] keys,
long[] pagePosition,
boolean longKey) |
Modifier and Type | Method and Description |
---|---|
void |
BtreePlusElementMgr.appendPageRecordable(IPageRecordable pageRecordable) |
String |
BtreePlusElementMgr.backup(long identifier,
int maxBackup) |
String |
BtreePlusDataManager.backup(long identifier,
int maxBackup) |
IntegrityCheckResult |
BtreePlusDataMgrIntegrityChecker.checkIntegrity(IHeapDataManager dataManager,
DataRecordIdentifier lessThanMinKey,
DataRecordIdentifier maxKey) |
void |
BtreePlusElementMgr.clear() |
protected void |
BtreePlusDataManager.clearImpl() |
protected void |
BtreePlusDataManager.clearStandbyModificationImpl() |
void |
BtreePlusElementMgr.closeTransaction() |
void |
BtreePlusElementMgr.closeTransactionDiscardChange() |
IDataBlock |
BtreePlusElementMgr.createDataBlock(byte[] data) |
IFileStorable |
BtreePlusElementMgr.createHeapRecord(IHeapElementManager heapElementManager,
long positionInFile) |
protected Iterator<DataRecordIdentifier> |
BtreePlusDataManager.dataRecordIteratorImpl() |
void |
BtreePlusElementMgr.decrementNumberOfDataRecord() |
protected boolean |
BtreePlusDataManager.deleteDataRecordImpl(DataRecordIdentifier dataRecordIdentifier) |
protected void |
BtreePlusDataManager.flushImp() |
void |
BtreePlusElementMgr.freePage(IPageRecord pageRecord) |
long |
BtreePlusElementMgr.freeSize() |
protected long |
BtreePlusDataManager.freeSizeImpl() |
byte[] |
BtreePlusElementMgr.getData(long dataBlockPosition) |
IDataBlock |
BtreePlusElementMgr.getDataBlock(long dataBlockPosition) |
protected Set<DataRecordIdentifier> |
BtreePlusDataManager.getDataRecordIdentifierSetImpl() |
long |
BtreePlusElementMgr.getLastRecordPositionInFile() |
long |
BtreePlusDataManager.getLastRecordPositionInFile() |
long |
BtreePlusElementMgr.getNewDataRecordIdentifier() |
protected DataRecordIdentifier |
BtreePlusDataManager.getNewDataRecordIdentifierImpl() |
protected DataRecordIdentifier |
BtreePlusDataManager.getNextFreeDataRecordIdentifierImpl() |
protected int |
BtreePlusDataManager.getNumberOfDataRecordImpl() |
int |
BtreePlusElementMgr.getNumberOfFreeRecord() |
protected int |
BtreePlusDataManager.getNumberOfFreeRecordImpl() |
IPageRecordable |
BtreePlusElementMgr.getPage(long position,
IPageRecordable parentPage,
int index) |
long |
BtreePlusDataManager.getRecordPositionInfile(DataRecordIdentifier identifier) |
IPageRecordable |
BtreePlusElementMgr.getRoot() |
String |
BtreePlusDataManager.getStorageFileName() |
protected boolean |
BtreePlusDataManager.hasDataRecordImpl(DataRecordIdentifier dataRecordIdentifier) |
long |
BtreePlusElementMgr.heapSize() |
protected long |
BtreePlusDataManager.heapSizeImpl() |
void |
BtreePlusElementMgr.incrementNumberOfDataRecord() |
void |
BtreePlusElementMgr.newRootLeafPage(DataRecordIdentifier dataRecordIdentifier,
IDataBlock dataBlock) |
void |
BtreePlusElementMgr.newRootNonTerminalPage(INonTerminalPage leftNonTerminalPage,
DataRecordIdentifier middleKey,
INonTerminalPage rightNonTerminalPage) |
void |
BtreePlusElementMgr.newRootNonTerminalPage(LeafPage leftLeafPage,
LeafPage rightLeafPage) |
void |
BtreePlusElementMgr.openTransaction() |
protected byte[] |
BtreePlusDataManager.readDataRecordImpl(DataRecordIdentifier dataRecordIdentifier) |
void |
BtreePlusElementMgr.remove(IDataBlock dataBlock) |
void |
BtreePlusElementMgr.removeFiles() |
protected void |
BtreePlusDataManager.removeFiles() |
protected DataRecordIdentifier |
BtreePlusDataManager.removeFirstDataRecordImpl() |
void |
BtreePlusElementMgr.removeRoot() |
void |
BtreePlusElementMgr.setDataRecordKeyManager(IDataRecordKeyManager dataRecordKeyManager) |
void |
BtreePlusDataManager.setDataRecordKeyManager(IDataRecordKeyManager dataRecordKeyManager) |
void |
BtreePlusElementMgr.setNextFreeDataRecordIdentifier(long value) |
protected void |
BtreePlusDataManager.setNextFreeDataRecordIdentifierImpl(DataRecordIdentifier dataRecordIdentifier) |
void |
BtreePlusElementMgr.startService() |
protected void |
BtreePlusDataManager.startServiceImpl(boolean removeFiles) |
void |
BtreePlusElementMgr.stopService() |
protected void |
BtreePlusDataManager.stopServiceImpl(boolean removeFiles) |
long |
BtreePlusElementMgr.usedSize() |
protected long |
BtreePlusDataManager.usedSizeImpl() |
protected boolean |
BtreePlusDataManager.writeDataRecordImpl(DataRecordIdentifier dataRecordIdentifier,
byte[] data) |
Constructor and Description |
---|
BtreePlusDataManager(HeapFileSetup setup) |
BtreePlusElementMgr(IHeapElementManager heapElementManager) |
Modifier and Type | Method and Description |
---|---|
void |
HeapHeader.addFreeSize(int newFreeAreaSize)
when an area is freed add to free and substract from used
|
void |
HeapHeader.addUsedSize(int newUsedAreaSize)
when a new used area is addes when add to used
|
void |
HeapRecord.freeRecord() |
byte[] |
HeapRecord.getDataAssociated() |
Integer |
HeapRecord.getDataAssociatedSize() |
IRBTNode<Integer> |
HeapRecord.getFreeNode() |
HeapRecord |
AbstractHeapRBTNode.getHeapRecord() |
IRBTNode<DataRecordIdentifier> |
HeapRecord.getIdNode() |
long |
HeapRecord.getNextRecordFilePosition() |
long |
HeapRecord.getPreviousRecordPositionInFile() |
long |
HeapHeader.getPreviousRecordPositionInFile() |
int |
HeapRecord.getRecordSize() |
int |
HeapHeader.getRecordSize() |
protected void |
HeapRecord.marshallImpl() |
protected void |
HeapHeader.marshallImpl() |
void |
HeapRecord.setDataAssociated(byte[] dataAssociated)
set data associated to this record
|
void |
HeapHeader.setEndOfRecordPositionInFile(long endOfRecordPositionInFile) |
void |
HeapHeader.setFreeRootNodeFilePosition(long freeRootNodeFilePosition) |
void |
HeapHeader.setIdRootNodeFilePosition(long idRootNodeFilePosition) |
void |
HeapHeader.setLastRecordPositionInFile(long lastRecordPositionInFile) |
void |
HeapHeader.setNextDataRecordIdentifier(DataRecordIdentifier nextDataRecordIdentifier) |
void |
HeapHeader.setNextDataRecordIdentifier(long value) |
void |
HeapRecord.setPreviousRecordPositionInFile(long previousRecordPositionInFile) |
protected int |
HeapRecord.toMarshallSize() |
void |
HeapRecord.unfreeRecord(int dataAssociatedSize,
DataRecordIdentifier nodeIdentifier) |
void |
HeapRecord.unfreeRecord(int dataAssociatedSize,
int recordSize,
DataRecordIdentifier nodeIdentifier,
boolean manageData) |
void |
HeapHeader.unfreeSize(int areaSize)
when area is unfreed add to used and substract from free
|
protected void |
HeapRecord.unmarshallImpl() |
protected void |
HeapHeader.unmarshallImpl() |
protected void |
HeapRecord.valueChangedAction() |
protected void |
HeapHeader.valueChangedAction() |
Constructor and Description |
---|
HeapRecord(IHeapElementManager heapElementManager,
long positionInFile)
construction for reading, unknown data associated size, and unknown node
identification
should be only used bye HeapElementManager |
HeapRecord(IHeapElementManager heapElementManager,
long positionInFile,
Long previousRecordPositionInFile,
DataRecordIdentifier nodeIdentifier,
boolean freeRecord,
int dataAssociatedSize,
int recordSize)
construction for node creation, it is a data record, not free should be
only used by
HeapElementManager |
Modifier and Type | Method and Description |
---|---|
protected IRBTNode<DataRecordIdentifier> |
HeapIdNodeManager.getRootNode(HeapHeader heapHeader) |
protected IRBTNode<Integer> |
HeapFreeNodeManager.getRootNode(HeapHeader heapHeader) |
protected abstract IRBTNode<E> |
AbstractHeapNodeManager.getRootNode(HeapHeader heapHeader)
the get root node implementation
|
Modifier and Type | Method and Description |
---|---|
void |
HeapFileDataManager.accept(IRBTVisitor<DataRecordIdentifier> visitor) |
String |
HeapFileDataManager.backup(long identifier,
int maxBackup) |
protected DataRecordIdentifier |
HeapFileDataManager.ceilingDataRecordIdentifierImpl(DataRecordIdentifier identifier) |
protected DataRecordIdentifier |
AutoSaveHeapFileDataManager.ceilingDataRecordIdentifierImpl(DataRecordIdentifier identifier) |
protected void |
HeapFileDataManager.clearImpl() |
protected void |
HeapFileDataManager.clearStandbyModificationImpl() |
IFileStorable |
HeapFileDataManager.createHeapRecord(IHeapElementManager heapElementManager,
long positionInFile) |
boolean |
HeapFileDataManager.deleteDataRecordImpl(DataRecordIdentifier dataRecordIdentifier) |
boolean |
AutoSaveHeapFileDataManager.deleteDataRecordImpl(DataRecordIdentifier dataRecordIdentifier) |
protected DataRecordIdentifier |
HeapFileDataManager.firstDataRecordIdentifierImpl() |
protected DataRecordIdentifier |
AutoSaveHeapFileDataManager.firstDataRecordIdentifierImpl() |
protected DataRecordIdentifier |
HeapFileDataManager.floorDataRecordIdentifierImpl(DataRecordIdentifier identifier) |
protected DataRecordIdentifier |
AutoSaveHeapFileDataManager.floorDataRecordIdentifierImpl(DataRecordIdentifier identifier) |
protected void |
HeapFileDataManager.flushImp() |
protected long |
HeapFileDataManager.freeSizeImpl() |
protected Set<DataRecordIdentifier> |
HeapFileDataManager.getDataRecordIdentifierSetImpl() |
long |
HeapFileDataManager.getLastRecordPositionInFile() |
protected DataRecordIdentifier |
HeapFileDataManager.getNewDataRecordIdentifierImpl() |
protected DataRecordIdentifier |
AutoSaveHeapFileDataManager.getNewDataRecordIdentifierImpl() |
protected DataRecordIdentifier |
HeapFileDataManager.getNextFreeDataRecordIdentifierImpl() |
protected DataRecordIdentifier |
AutoSaveHeapFileDataManager.getNextFreeDataRecordIdentifierImpl() |
protected int |
HeapFileDataManager.getNumberOfDataRecordImpl() |
protected int |
HeapFileDataManager.getNumberOfFreeRecordImpl() |
long |
HeapFileDataManager.getRecordPositionInfile(DataRecordIdentifier identifier) |
long |
AutoSaveHeapFileDataManager.getRecordPositionInfile(DataRecordIdentifier identifier) |
String |
HeapFileDataManager.getStorageFileName() |
protected boolean |
HeapFileDataManager.hasDataRecordImpl(DataRecordIdentifier dataRecordIdentifier) |
protected boolean |
AutoSaveHeapFileDataManager.hasDataRecordImpl(DataRecordIdentifier dataRecordIdentifier) |
protected long |
HeapFileDataManager.heapSizeImpl() |
protected DataRecordIdentifier |
HeapFileDataManager.higherDataRecordIdentifierImpl(DataRecordIdentifier identifier) |
protected DataRecordIdentifier |
AutoSaveHeapFileDataManager.higherDataRecordIdentifierImpl(DataRecordIdentifier identifier) |
protected DataRecordIdentifier |
HeapFileDataManager.lastDataRecordIdentifierImpl() |
protected DataRecordIdentifier |
AutoSaveHeapFileDataManager.lastDataRecordIdentifierImpl() |
protected DataRecordIdentifier |
HeapFileDataManager.lowerDataRecordIdentifierImpl(DataRecordIdentifier identifier) |
protected DataRecordIdentifier |
AutoSaveHeapFileDataManager.lowerDataRecordIdentifierImpl(DataRecordIdentifier identifier) |
DataRecordIdentifier |
HeapFileDataManager.nextDataRecordIdentifier(DataRecordIdentifier dataRecordIdentifier) |
DataRecordIdentifier |
AutoSaveHeapFileDataManager.nextDataRecordIdentifierImpl(DataRecordIdentifier dataRecordIdentifier) |
byte[] |
HeapFileDataManager.readDataRecordImpl(DataRecordIdentifier dataRecordIdentifier) |
byte[] |
AutoSaveHeapFileDataManager.readDataRecordImpl(DataRecordIdentifier dataRecordIdentifier) |
protected void |
HeapFileDataManager.removeFiles() |
protected DataRecordIdentifier |
HeapFileDataManager.removeFirstDataRecordImpl() |
protected void |
HeapFileDataManager.setNextFreeDataRecordIdentifierImpl(DataRecordIdentifier dataRecordIdentifier) |
protected void |
AutoSaveHeapFileDataManager.setNextFreeDataRecordIdentifierImpl(DataRecordIdentifier dataRecordIdentifier) |
protected void |
HeapFileDataManager.startServiceImpl(boolean removeFiles) |
protected void |
HeapFileDataManager.stopServiceImpl(boolean removeFiles) |
protected long |
HeapFileDataManager.usedSizeImpl() |
boolean |
HeapFileDataManager.writeDataRecordImpl(DataRecordIdentifier dataRecordIdentifier,
byte[] data) |
boolean |
AutoSaveHeapFileDataManager.writeDataRecordImpl(DataRecordIdentifier dataRecordIdentifier,
byte[] data) |
Constructor and Description |
---|
AutoSaveHeapFileDataManager(HeapFileSetup setup,
boolean manageNodeIndex,
int maxRecord) |
HeapFileDataManager(HeapFileSetup setup,
boolean manageNodeIndex) |
Modifier and Type | Method and Description |
---|---|
void |
HeapFileSetup.cacheSetup(int pageSize,
int maxPage)
setup of cache parameters
|
void |
HeapFileSetup.crashSafeSetup(File backupDataFile,
File stateOkFlagFile,
File stateBackupOkFlagFile,
File globalStateFlagFile)
setup of crash safe mode parameters
|
void |
HeapFileSetup.fileBufferSetup(int maxBufferSize,
int maxNumberOfBuffer) |
File |
HeapFileSetup.getBackupDataFile() |
FileAccessParameter |
HeapFileSetup.getBackupFileAccessParameter() |
FileAccessParameter |
HeapFileSetup.getDataFileAccessParameter() |
File |
FileAccessParameter.getFile() |
EnumFileAccessMode |
FileAccessParameter.getFileAccessMode() |
File |
HeapFileSetup.getGlobalStateFlagFile() |
int |
FileAccessParameter.getMaxBufferSize() |
int |
FileAccessParameter.getMaxNumberOfBuffer() |
int |
HeapFileSetup.getMaxPage() |
int |
FileAccessParameter.getMaxPage() |
int |
FileAccessParameter.getMaxRetry() |
int |
HeapFileSetup.getPageSize() |
int |
FileAccessParameter.getPageSize() |
long |
NullFileStorable.getPreviousRecordPositionInFile() |
long |
IFileStorable.getPreviousRecordPositionInFile() |
int |
NullFileStorable.getRecordSize() |
int |
IFileStorable.getRecordSize()
get the record size
|
int |
FileAccessParameter.getRetryMsDelay() |
File |
HeapFileSetup.getStateBackupOkFlagFile() |
File |
HeapFileSetup.getStateOkFlagFile() |
boolean |
FileAccessParameter.isUseCache() |
boolean |
FileAccessParameter.isUseReadCache() |
protected abstract void |
AbstractFileStorable.marshallImpl()
marshaling implementation for write
#crc32 is set to zero |
protected void |
AbstractFileStorable.readAndCheckCrc32(int offset) |
protected boolean |
AbstractFileStorable.readBoolean() |
protected byte |
AbstractFileStorable.readByte() |
protected void |
AbstractFileStorable.readBytes(byte[] destination)
read bytes
|
protected byte[] |
AbstractFileStorable.readBytes(int length)
read bytes
|
protected int |
AbstractFileStorable.readFileAppendToIoBuffer(int newSize)
read extending ioBuffer
|
protected int |
AbstractFileStorable.readFileToIoBuffer(int size) |
void |
NullFileStorable.readFromFile() |
void |
IFileStorable.readFromFile()
read this file storable from file
|
void |
AbstractFileStorable.readFromFile() |
protected int |
AbstractFileStorable.readInteger() |
protected long |
AbstractFileStorable.readLong()
unmarshal from byte array current
#dataByteArrayIndex index to
long#dataByteArrayIndex is updated to next data to read position |
void |
NullFileStorable.setValueIsChangedValueToSave() |
void |
IFileStorable.setValueIsChangedValueToSave()
set this record have value changed, so to save
|
void |
AbstractFileStorable.setValueIsChangedValueToSave() |
protected abstract int |
AbstractFileStorable.toMarshallSize() |
protected abstract void |
AbstractFileStorable.unmarshallImpl()
Unmarshalling implementation for read
#crc32 is set to zero |
protected abstract void |
AbstractFileStorable.valueChangedAction() |
protected void |
AbstractFileStorable.writeBoolean(boolean value) |
protected void |
AbstractFileStorable.writeByte(byte value) |
protected void |
AbstractFileStorable.writeBytes(byte[] dataByteArray)
write bytes
|
protected void |
AbstractFileStorable.writeCrc32(int offset) |
protected void |
AbstractFileStorable.writeInteger(int value) |
protected void |
AbstractFileStorable.writeLong(long value)
Marshal long value to byte array current
#dataByteArrayIndex
index#dataByteArrayIndex is updated to next data to write position |
void |
NullFileStorable.writeToFile() |
void |
IFileStorable.writeToFile()
write this file storable to file
|
void |
AbstractFileStorable.writeToFile() |
byte[] |
NullFileStorable.writeToFileGetWrited() |
byte[] |
IFileStorable.writeToFileGetWrited() |
byte[] |
AbstractFileStorable.writeToFileGetWrited() |
Constructor and Description |
---|
HeapFileSetup(EnumFileAccessMode fileAccessMode,
File dataFile,
boolean crashSafeMode,
boolean useCacheMode,
boolean deleteRenaming,
boolean clearResizeFile,
int maxFileOperationRetry,
int fileOperationRetryMsDelay,
File openFileTraceFile) |
Modifier and Type | Method and Description |
---|---|
int |
IDataRecordKey.compareTo(IDataRecordKey dataRecordKey) |
int |
DataRecordKey.compareTo(IDataRecordKey dataRecordKey) |
Object |
IDataRecordKey.getKey() |
Object |
DataRecordKey.getKey() |
Object |
DataRecordIdentifier.getKey() |
Modifier and Type | Method and Description |
---|---|
void |
IHeapElementManager.appendHeapFileRecord(IFileStorable heapRecord)
append an heap file record that will be to write in file
|
void |
HeapElementManager.appendHeapFileRecord(IFileStorable heapRecord) |
String |
IHeapElementManager.backup(long identifier,
int maxBackup) |
String |
HeapElementManager.backup(long identifier,
int maxBackup) |
void |
IHeapElementManager.clear()
clear heap content
service must be started and transaction opened |
void |
HeapElementManager.clear() |
void |
IHeapElementManager.closeTransaction()
close the heap file transaction management committing the modifications
to the file before
|
void |
HeapElementManager.closeTransaction() |
void |
IHeapElementManager.closeTransactionDiscardChange()
close the heap file transaction management without commit modification in
file
|
void |
HeapElementManager.closeTransactionDiscardChange() |
int |
IDataRecordKeyManager.compareDataRecordKey(IDataRecordKey dataRecordKey1,
IDataRecordKey dataRecordKey2) |
int |
AbstractDataRecordKeyComparator.compareDataRecordKey(IDataRecordKey dataRecordKey1,
IDataRecordKey dataRecordKey2) |
static IHeapElementManager |
HeapElementManagerFactory.create(HeapFileSetup setup) |
IFileStorable |
IHeapRecordFactory.createHeapRecord(IHeapElementManager heapElementManager,
long positionInFile)
creation for reading
|
DataRecordIdentifier |
IDataRecordKeyManager.createKey(Object key) |
DataRecordIdentifier |
DataRecordKeyManager.createKey(Object key) |
void |
IHeapElementManager.delete(long positionInFile) |
void |
HeapElementManager.delete(long positionInFile) |
long |
IHeapElementManager.getFileSize() |
long |
HeapElementManager.getFileSize() |
IFileStorable |
IHeapElementManager.getHeapHeader() |
IFileStorable |
HeapElementManager.getHeapHeader() |
void |
IHeapElementManager.openTransaction()
open the heap file transaction management
|
void |
HeapElementManager.openTransaction() |
IFileStorable |
IHeapElementManager.readHeapFileDataRecord(long positionInFile)
read heap record in file
|
IFileStorable |
HeapElementManager.readHeapFileDataRecord(long positionInFile) |
void |
IHeapElementManager.removeFiles()
removes files containing heap data
transaction must be closed and service stopped |
void |
HeapElementManager.removeFiles() |
void |
IHeapElementManager.setHeapHeader(IFileStorable heapHeader)
set heap header
|
void |
HeapElementManager.setHeapHeader(IFileStorable heapHeader) |
void |
IHeapElementManager.startService()
start heap record management service
|
void |
HeapElementManager.startService() |
void |
IHeapElementManager.stopService()
stop heap record management service
|
void |
HeapElementManager.stopService() |
Comparable<?> |
IDataRecordKeyManager.unmarshall(byte[] keyData) |
Comparable<?> |
DataRecordKeyManager.unmarshall(byte[] keyData) |
boolean |
IHeapElementManager.wasBadFileStableState()
check file stable state, restore if possible
service must not be started must be called before heap file access |
boolean |
HeapElementManager.wasBadFileStableState() |
Modifier and Type | Method and Description |
---|---|
protected HeapException |
FileForStorable.closeAfterIOException(String message,
FileIOException exception)
close after io exception
|
Modifier and Type | Method and Description |
---|---|
String |
IHeapDataManager.backup(long identifier,
int maxBackup) |
DataRecordIdentifier |
IHeapDataManager.ceilingDataRecordIdentifier(DataRecordIdentifier dataRecordIdentifier) |
DataRecordIdentifier |
AbstractHeapDataManager.ceilingDataRecordIdentifier(DataRecordIdentifier dataRecordIdentifier) |
protected DataRecordIdentifier |
AbstractHeapDataManager.ceilingDataRecordIdentifierImpl(DataRecordIdentifier dataRecordIdentifier) |
void |
IHeapDataManager.clear()
clear the heap content.
|
void |
AbstractHeapDataManager.clear() |
protected abstract void |
AbstractHeapDataManager.clearImpl() |
void |
IHeapDataManager.clearStandbyModification()
clear creation, modification, and deletion to do on the heap.
|
void |
AbstractHeapDataManager.clearStandbyModification() |
protected abstract void |
AbstractHeapDataManager.clearStandbyModificationImpl() |
void |
IFileForStorable.close()
close heap file access operation
|
void |
FileForStorable.close() |
protected HeapException |
FileForStorable.closeAfterIOException(String message,
FileIOException exception)
close after io exception
|
void |
IFileForStorable.copy(FileForStorable fileForStorable)
copy this file to an other file
|
void |
FileForStorable.copy(FileForStorable fileForStorable) |
Iterator<DataRecordIdentifier> |
IHeapDataManager.dataRecordIterator() |
Iterator<DataRecordIdentifier> |
AbstractHeapDataManager.dataRecordIterator() |
protected abstract Iterator<DataRecordIdentifier> |
AbstractHeapDataManager.dataRecordIteratorImpl() |
boolean |
IHeapDataManager.deleteDataRecord(DataRecordIdentifier dataRecordIdentifier)
delete an existing data record knowing its identifier.
|
boolean |
AbstractHeapDataManager.deleteDataRecord(DataRecordIdentifier dataRecordIdentifier) |
protected abstract boolean |
AbstractHeapDataManager.deleteDataRecordImpl(DataRecordIdentifier dataRecordIdentifier) |
void |
IFileForStorable.deleteFileIfExists()
delete file if exists
|
void |
FileForStorable.deleteFileIfExists() |
void |
IFileForStorable.deleteFileIfExistsRenaming()
delete file if exists
|
void |
FileForStorable.deleteFileIfExistsRenaming() |
DataRecordIdentifier |
IHeapDataManager.firstDataRecordIdentifier() |
DataRecordIdentifier |
AbstractHeapDataManager.firstDataRecordIdentifier() |
protected DataRecordIdentifier |
AbstractHeapDataManager.firstDataRecordIdentifierImpl() |
DataRecordIdentifier |
IHeapDataManager.floorDataRecordIdentifier(DataRecordIdentifier dataRecordIdentifier) |
DataRecordIdentifier |
AbstractHeapDataManager.floorDataRecordIdentifier(DataRecordIdentifier dataRecordIdentifier) |
protected DataRecordIdentifier |
AbstractHeapDataManager.floorDataRecordIdentifierImpl(DataRecordIdentifier dataRecordIdentifier) |
void |
IHeapDataManager.flush()
flush creation, modification, and deletion to the heap
the heap is updated. |
void |
IFileForStorable.flush()
flush modification to disk
|
void |
FileForStorable.flush() |
void |
AbstractHeapDataManager.flush() |
protected abstract void |
AbstractHeapDataManager.flushImp()
implement all flush action after call to
#updateHeapRecordImpl(DataRecordIdentifier, IHeapDataRecord) |
long |
IHeapDataManager.freeSize()
get heap total free size in bytes.
|
long |
AbstractHeapDataManager.freeSize() |
protected abstract long |
AbstractHeapDataManager.freeSizeImpl() |
Set<DataRecordIdentifier> |
IHeapDataManager.getDataRecordIdentifierSet()
for test purpose
|
Set<DataRecordIdentifier> |
AbstractHeapDataManager.getDataRecordIdentifierSet() |
protected abstract Set<DataRecordIdentifier> |
AbstractHeapDataManager.getDataRecordIdentifierSetImpl() |
long |
IFileForStorable.getFileSize()
Returns the size of this file.
|
long |
FileForStorable.getFileSize() |
long |
IHeapDataManager.getLastRecordPositionInFile()
for test purpose
|
DataRecordIdentifier |
IHeapDataManager.getNewDataRecordIdentifier()
to get a new data identifier for data record creation: return the next
free data record identifier and internally increment the next free data
record identifier
when created #readHeapDataRecord(DataRecordIdentifier) can be
used for the data record identifierIHeapDataManager.flush() must be call to store the modification. |
DataRecordIdentifier |
AbstractHeapDataManager.getNewDataRecordIdentifier() |
protected abstract DataRecordIdentifier |
AbstractHeapDataManager.getNewDataRecordIdentifierImpl()
to get a new data identifier for future data record creation
|
DataRecordIdentifier |
IHeapDataManager.getNextFreeDataRecordIdentifier()
get the next free data record identifier
|
DataRecordIdentifier |
AbstractHeapDataManager.getNextFreeDataRecordIdentifier() |
protected abstract DataRecordIdentifier |
AbstractHeapDataManager.getNextFreeDataRecordIdentifierImpl() |
int |
IHeapDataManager.getNumberOfDataRecord()
get number of data record in heap file.
|
int |
AbstractHeapDataManager.getNumberOfDataRecord() |
protected abstract int |
AbstractHeapDataManager.getNumberOfDataRecordImpl() |
int |
IHeapDataManager.getNumberOfFreeRecord()
get number of free record in heap file.
|
int |
AbstractHeapDataManager.getNumberOfFreeRecord() |
protected abstract int |
AbstractHeapDataManager.getNumberOfFreeRecordImpl() |
long |
IHeapDataManager.getRecordPositionInfile(DataRecordIdentifier identifier)
for test purpose
|
String |
IHeapDataManager.getStorageFileName() |
boolean |
IHeapDataManager.hasDataRecord(DataRecordIdentifier dataRecordIdentifier)
to check if have data record for a data record identifier.
|
boolean |
AbstractHeapDataManager.hasDataRecord(DataRecordIdentifier dataRecordIdentifier) |
protected abstract boolean |
AbstractHeapDataManager.hasDataRecordImpl(DataRecordIdentifier dataRecordIdentifier) |
long |
IHeapDataManager.heapSize()
get heap total size in bytes.
|
long |
AbstractHeapDataManager.heapSize() |
protected abstract long |
AbstractHeapDataManager.heapSizeImpl() |
DataRecordIdentifier |
IHeapDataManager.higherDataRecordIdentifier(DataRecordIdentifier dataRecordIdentifier) |
DataRecordIdentifier |
AbstractHeapDataManager.higherDataRecordIdentifier(DataRecordIdentifier dataRecordIdentifier) |
protected DataRecordIdentifier |
AbstractHeapDataManager.higherDataRecordIdentifierImpl(DataRecordIdentifier dataRecordIdentifier) |
DataRecordIdentifier |
IHeapDataManager.lastDataRecordIdentifier() |
DataRecordIdentifier |
AbstractHeapDataManager.lastDataRecordIdentifier() |
protected DataRecordIdentifier |
AbstractHeapDataManager.lastDataRecordIdentifierImpl() |
DataRecordIdentifier |
IHeapDataManager.lowerDataRecordIdentifier(DataRecordIdentifier dataRecordIdentifier) |
DataRecordIdentifier |
AbstractHeapDataManager.lowerDataRecordIdentifier(DataRecordIdentifier dataRecordIdentifier) |
protected DataRecordIdentifier |
AbstractHeapDataManager.lowerDataRecordIdentifierImpl(DataRecordIdentifier dataRecordIdentifier) |
DataRecordIdentifier |
IHeapDataManager.nextDataRecordIdentifier(DataRecordIdentifier dataRecordIdentifier) |
DataRecordIdentifier |
AbstractHeapDataManager.nextDataRecordIdentifier(DataRecordIdentifier dataRecordIdentifier) |
protected DataRecordIdentifier |
AbstractHeapDataManager.nextDataRecordIdentifierImpl(DataRecordIdentifier dataRecordIdentifier) |
void |
IFileForStorable.open()
open heap file for access operation
|
void |
FileForStorable.open() |
int |
IFileForStorable.read(byte[] data)
delegate to
RandomAccessFile.read(byte[]) closing the file in
case of I/O errorReads up to data.length bytes of data from this file into an
array of bytes. |
int |
FileForStorable.read(byte[] data) |
int |
IFileForStorable.read(byte[] data,
int offset,
int length) |
int |
FileForStorable.read(byte[] data,
int offset,
int length) |
byte[] |
IHeapDataManager.readDataRecord(DataRecordIdentifier dataRecordIdentifier)
read data for a data record.
|
byte[] |
AbstractHeapDataManager.readDataRecord(DataRecordIdentifier dataRecordIdentifier) |
protected abstract byte[] |
AbstractHeapDataManager.readDataRecordImpl(DataRecordIdentifier dataRecordIdentifier) |
protected abstract void |
AbstractHeapDataManager.removeFiles()
remove existing files
|
DataRecordIdentifier |
IHeapDataManager.removeFirstDataRecord()
remove first data record and return its data record identifier.
|
DataRecordIdentifier |
AbstractHeapDataManager.removeFirstDataRecord() |
protected abstract DataRecordIdentifier |
AbstractHeapDataManager.removeFirstDataRecordImpl() |
void |
IFileForStorable.resetFileSize() |
void |
FileForStorable.resetFileSize() |
void |
IFileForStorable.seek(long positionInFile)
delegate to
RandomAccessFile.seek(long) closing the file in case
of I/O error |
void |
FileForStorable.seek(long positionInFile) |
void |
IHeapDataManager.setDataRecordKeyManager(IDataRecordKeyManager dataRecordKeyComparator) |
void |
FileForStorable.setFileSize(long newSize)
set the size of this file
|
void |
IHeapDataManager.setNextFreeDataRecordIdentifier(DataRecordIdentifier dataRecordIdentifier)
set the next free data record identifier.
|
void |
AbstractHeapDataManager.setNextFreeDataRecordIdentifier(DataRecordIdentifier dataRecordIdentifier) |
protected abstract void |
AbstractHeapDataManager.setNextFreeDataRecordIdentifierImpl(DataRecordIdentifier dataRecordIdentifier) |
void |
IHeapDataManager.startService(boolean removeFiles)
start heap data manager service.
|
void |
AbstractHeapDataManager.startService(boolean removeFiles) |
protected abstract void |
AbstractHeapDataManager.startServiceImpl(boolean removeFiles)
to implement open actions
|
void |
IHeapDataManager.stopService()
stop heap data manager service, do not flush in file any modification.
|
void |
AbstractHeapDataManager.stopService() |
void |
IHeapDataManager.stopService(boolean removeFiles) |
void |
AbstractHeapDataManager.stopService(boolean removeFiles) |
protected abstract void |
AbstractHeapDataManager.stopServiceImpl(boolean removeFiles)
to implement close actions
|
long |
IHeapDataManager.usedSize()
get heap total used size in bytes.
|
long |
AbstractHeapDataManager.usedSize() |
protected abstract long |
AbstractHeapDataManager.usedSizeImpl() |
void |
IFileForStorable.write(byte[] data)
delegate to
RandomAccessFile#write(byte[])) closing the file in
case of I/O error |
void |
FileForStorable.write(byte[] data) |
void |
IFileForStorable.write(byte[] data,
int offset,
int length) |
void |
FileForStorable.write(byte[] data,
int offset,
int length) |
void |
IFileForStorable.write(ToBackupRecord toBackupRecord) |
void |
FileForStorable.write(ToBackupRecord toBackupRecord) |
boolean |
IHeapDataManager.writeDataRecord(DataRecordIdentifier dataRecordIdentifier,
byte[] data)
write data record.
|
boolean |
AbstractHeapDataManager.writeDataRecord(DataRecordIdentifier dataRecordIdentifier,
byte[] data) |
protected abstract boolean |
AbstractHeapDataManager.writeDataRecordImpl(DataRecordIdentifier dataRecordIdentifier,
byte[] data) |
Constructor and Description |
---|
FileForStorable(FileAccessParameter fileAccessParameter)
create a file to read from and write to
IFileStorable object |
Modifier and Type | Method and Description |
---|---|
protected void |
InserterBtreePlusWhithCache.consistencyCheck() |
protected void |
InserterBtreePlusIntigrityCheck.consistencyCheck() |
protected void |
DeleterBtreePlus.consistencyCheck() |
protected abstract void |
AbstractInserter.consistencyCheck() |
protected abstract void |
AbstractDeleter.consistencyCheck() |
protected void |
InserterBtreePlusWhithCache.run() |
protected void |
AbstractDeleter.run(String insertLogFilePath,
String pathName,
IHeapDataManager dataManager,
Boolean useCache) |
protected void |
AbstractInserter.run(String insertLogFilePath,
String pathName,
IHeapDataManager dataManager,
Boolean useCache,
int numberOfItem) |
Modifier and Type | Method and Description |
---|---|
void |
FileTreeMap.clearStandbyModification() |
void |
FileTreeMap.flush() |
void |
FileTreeMap.startService(boolean removeFiles) |
void |
FileTreeMap.stopService() |
Constructor and Description |
---|
FileTreeMap(HeapFileSetup setup,
Integer autoSaveMaxRecord) |
FileTreeMap(HeapFileSetup setup,
Integer autoSaveMaxRecord,
Comparator<? super K> comparator) |
FileTreeMap(HeapFileSetup setup,
Integer autoSaveMaxRecord,
Map<? extends K,? extends V> map) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractCrash.simulateCrashDataLost() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractStoreDelegatingToDataManager.flushDataManager() |
protected DataRecordIdentifier |
AbstractStoreDelegatingToDataManager.getNewDataRecordIdentifier() |
protected void |
AbstractStoreDelegatingToDataManager.startDataManagerService(boolean removeFiles) |
protected void |
AbstractStoreDelegatingToDataManager.stopDataManagerService() |
Modifier and Type | Method and Description |
---|---|
void |
PersistantDataRecordIdentifierSetQue.addDataRecordIdentifier(DataRecordIdentifier dataRecordIdentifier) |
void |
PersistantDataRecordIdentifierSetQue.close() |
int |
PersistantDataRecordIdentifierSetQue.getNumberExported() |
void |
PersistantDataRecordIdentifierSetQue.initialize() |
DataRecordIdentifier |
PersistantDataRecordIdentifierSetQue.pollFirst() |
Constructor and Description |
---|
PersistantDataRecordIdentifierSetQue(String directoryName) |
Modifier and Type | Method and Description |
---|---|
void |
PersistantDataRecordIdentifierSet.startService(boolean removeFiles) |
void |
PersistantDataRecordIdentifierSet.stopService() |
void |
PersistantDataRecordIdentifierSet.stopService(boolean removeFiles) |
Constructor and Description |
---|
PersistantDataRecordIdentifierSet(String filePath) |
Copyright © 2007-2012 Luc Peuvrier. All Rights Reserved.