Package com.gigaspaces.internal.server.space.redolog.storage

Class SqliteRedoLogFileStorage<T extends IReplicationOrderedPacket>

java.lang.Object

com.gigaspaces.internal.server.space.redolog.storage.SqliteStorageLayer<T>

com.gigaspaces.internal.server.space.redolog.storage.SqliteRedoLogFileStorage<T>

All Implemented Interfaces:

IRedoLogFileStorage<T>, IRedoLogFileStorageStatistics

public class SqliteRedoLogFileStorage<T extends IReplicationOrderedPacket>
extends SqliteStorageLayer<T>
implements IRedoLogFileStorage<T>

Nested Class Summary

Nested classes/interfaces inherited from class com.gigaspaces.internal.server.space.redolog.storage.SqliteStorageLayer

SqliteStorageLayer.RDBMSRedoLogIterator

Field Summary

Fields inherited from class com.gigaspaces.internal.server.space.redolog.storage.SqliteStorageLayer

COLUMN_NAMES, connection, OPERATION_TYPE_COLUMN_INDEX, PACKET_COLUMN_INDEX, PACKET_COUNT_COLUMN_INDEX, PACKET_WEIGHT_COLUMN_INDEX, REDO_KEY_COLUMN_INDEX, TABLE_NAME, TYPE_NAME_COLUMN_INDEX, UID_COLUMN_INDEX

Constructor Summary

Constructors

Constructor	Description
SqliteRedoLogFileStorage(DBSwapRedoLogFileConfig<T> config)

Method Summary

Modifier and Type	Method	Description
void	appendBatch(List<T> replicationPackets)	Adds a batch of packets that will be stored at the end of the list
void	close()	Close the storage and clears its resources, the storage can no longer be used.
void	deleteOldestPackets(long packetsCount)	Delete a batch from the start of the list
long	getCacheWeight()
long	getDiscardedPacketsCount()
long	getExternalPacketsCount()
long	getExternalStoragePacketsWeight()
long	getMemoryPacketsCount()
long	getMemoryPacketsWeight()
T	getOldest()
long	getOldestKey()
long	getSpaceUsed()
long	getWeight()
boolean	isEmpty()
CompactionResult	performCompaction(long from, long to)
StorageReadOnlyIterator<T>	readOnlyIterator(long fromIndex)
WeightedBatch<T>	removeFirstBatch(int batchCapacity, long lastCompactionRangeEndKey)	Removes a batch from the start of the list
T	removeOldest()
long	size()	This method should not assume a reader lock is obtained when accessing it
void	validateIntegrity()	Validates the integrity of the storage

Methods inherited from class com.gigaspaces.internal.server.space.redolog.storage.SqliteStorageLayer

deleteDataFile, deserializePacket, dropTable, executeCreateTable, executeDelete, executeInsert, executeQuery, getPacketCount, getPacketOperationTypeName, getPacketTypeName, getPacketUID, getPacketWeight, getStorageRedoLogSize, serializePacket

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SqliteRedoLogFileStorage

public SqliteRedoLogFileStorage(DBSwapRedoLogFileConfig<T> config)

Method Details

appendBatch

public void appendBatch(List<T> replicationPackets)
                 throws StorageException

Description copied from interface: IRedoLogFileStorage

Adds a batch of packets that will be stored at the end of the list

Specified by:

appendBatch in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

Parameters:

replicationPackets - packets to store

Throws:

StorageException

size

public long size()
          throws StorageException

Description copied from interface: IRedoLogFileStorage

This method should not assume a reader lock is obtained when accessing it

Specified by:

size in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

Returns:

number of packets in the storage

Throws:

StorageException

removeFirstBatch

public WeightedBatch<T> removeFirstBatch(int batchCapacity,
 long lastCompactionRangeEndKey)
                                  throws StorageException

Description copied from interface: IRedoLogFileStorage

Removes a batch from the start of the list

Specified by:

removeFirstBatch in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

Parameters:

batchCapacity - WeightToRemove to remove

lastCompactionRangeEndKey - packets with keys larger than this cannot be discarded

Returns:

removed batch

Throws:

StorageException

deleteOldestPackets

public void deleteOldestPackets(long packetsCount)
                         throws StorageException

Description copied from interface: IRedoLogFileStorage

Delete a batch from the start of the list

Specified by:

deleteOldestPackets in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

Parameters:

packetsCount - number of packets to delete

Throws:

StorageException

readOnlyIterator

public StorageReadOnlyIterator<T> readOnlyIterator(long fromIndex)
                                            throws StorageException

Specified by:

readOnlyIterator in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

Parameters:

fromIndex - index to start iterating from

Returns:

read only iterator that starts from the specified index

Throws:

StorageException

isEmpty

public boolean isEmpty()
                throws StorageException

Specified by:

isEmpty in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

Returns:

true if the storage has no packets

Throws:

StorageException

validateIntegrity

public void validateIntegrity()
                       throws RedoLogFileCompromisedException

Description copied from interface: IRedoLogFileStorage

Validates the integrity of the storage

Specified by:

validateIntegrity in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

Throws:

RedoLogFileCompromisedException

getOldest

public T getOldest()
            throws StorageException

Specified by:

getOldest in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

Throws:

StorageException

removeOldest

public T removeOldest()
               throws StorageException

Specified by:

removeOldest in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

Throws:

StorageException

getOldestKey

public long getOldestKey()

Specified by:

getOldestKey in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

close

public void close()

Description copied from interface: IRedoLogFileStorage

Close the storage and clears its resources, the storage can no longer be used.

Specified by:

close in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

getWeight

public long getWeight()

Specified by:

getWeight in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

getDiscardedPacketsCount

public long getDiscardedPacketsCount()

Specified by:

getDiscardedPacketsCount in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

performCompaction

public CompactionResult performCompaction(long from,
 long to)

Specified by:

performCompaction in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

getCacheWeight

public long getCacheWeight()

Specified by:

getCacheWeight in interface IRedoLogFileStorage<T extends IReplicationOrderedPacket>

getSpaceUsed

public long getSpaceUsed()

Specified by:

getSpaceUsed in interface IRedoLogFileStorageStatistics

Returns:

used space in bytes

getExternalPacketsCount

public long getExternalPacketsCount()

Specified by:

getExternalPacketsCount in interface IRedoLogFileStorageStatistics

Returns:

number of packets held outside of jvm memory

getMemoryPacketsCount

public long getMemoryPacketsCount()

Specified by:

getMemoryPacketsCount in interface IRedoLogFileStorageStatistics

Returns:

number of packets held in jvm memory

getMemoryPacketsWeight

public long getMemoryPacketsWeight()

Specified by:

getMemoryPacketsWeight in interface IRedoLogFileStorageStatistics

Returns:

total weight of packets held in memory

getExternalStoragePacketsWeight

public long getExternalStoragePacketsWeight()

Specified by:

getExternalStoragePacketsWeight in interface IRedoLogFileStorageStatistics

Returns:

total weight of packets held in external storage