| Modifier and Type | Method and Description |
|---|---|
WALPointer |
IgniteWriteAheadLogManager.log(WALRecord entry)
Appends the given log entry to the write-ahead log.
|
WALPointer |
WALPointer.next()
Pointer to the next record.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteWriteAheadLogManager.allowCompressionUntil(WALPointer ptr)
Gives a hint to WAL manager to compact WAL until given pointer (exclusively).
|
void |
IgniteWriteAheadLogManager.flush(WALPointer ptr,
boolean explicitFsync)
Makes sure that all log entries written to the log up until the specified pointer are actually written
to the underlying storage.
|
void |
IgniteWriteAheadLogManager.release(WALPointer start)
Invoke this method to release WAL history since provided pointer that was previously reserved.
|
WALIterator |
IgniteWriteAheadLogManager.replay(WALPointer start)
Invoke this method to iterate over the written log entries.
|
boolean |
IgniteWriteAheadLogManager.reserve(WALPointer start)
Invoke this method to reserve WAL history since provided pointer and prevent it's deletion.
|
boolean |
IgniteWriteAheadLogManager.reserved(WALPointer ptr)
Checks if WAL segment is under lock or reserved
|
void |
IgniteWriteAheadLogManager.resumeLogging(WALPointer lastWrittenPtr)
Resumes logging after start.
|
int |
IgniteWriteAheadLogManager.truncate(WALPointer low,
WALPointer high)
Gives a hint to WAL manager to clear entries logged before the given pointer.
|
| Modifier and Type | Method and Description |
|---|---|
WALPointer |
CheckpointRecord.checkpointMark() |
WALPointer |
WALRecord.position() |
| Modifier and Type | Method and Description |
|---|---|
void |
WALRecord.position(WALPointer pos) |
| Constructor and Description |
|---|
CheckpointRecord(UUID cpId,
WALPointer cpMark) |
CheckpointRecord(UUID cpId,
WALPointer cpMark,
boolean end)
Constructor kept for serializer
|
CheckpointRecord(WALPointer cpMark) |
MarshalledRecord(WALRecord.RecordType type,
WALPointer pos,
ByteBuffer buf) |
| Modifier and Type | Method and Description |
|---|---|
WALPointer |
GridCacheUpdateTxResult.loggedPointer() |
protected WALPointer |
GridCacheMapEntry.logTxUpdate(IgniteInternalTx tx,
CacheObject val,
long expireTime,
long updCntr) |
| Modifier and Type | Method and Description |
|---|---|
protected WALPointer |
GridDhtDetachedCacheEntry.logTxUpdate(IgniteInternalTx tx,
CacheObject val,
long expireTime,
long updCntr) |
| Modifier and Type | Method and Description |
|---|---|
protected WALPointer |
GridNearCacheEntry.logTxUpdate(IgniteInternalTx tx,
CacheObject val,
long expireTime,
long updCntr) |
| Modifier and Type | Method and Description |
|---|---|
WALPointer |
GridCacheDatabaseSharedManager.searchPartitionCounter(int grpId,
int part,
Long partCntrSince)
Tries to search for a WAL pointer for the given partition counter start.
|
| Modifier and Type | Method and Description |
|---|---|
List<T2<Long,WALPointer>> |
GridCacheDatabaseSharedManager.nodeStartedPointers() |
Map<T2<Integer,Integer>,T2<Long,WALPointer>> |
GridCacheDatabaseSharedManager.reservedForPreloading()
For debugging only.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheDatabaseSharedManager.onWalTruncated(WALPointer highBound)
Wal truncate callBack.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheDatabaseSharedManager.applyUpdatesOnRecovery(WALIterator it,
IgnitePredicate<IgniteBiTuple<WALPointer,WALRecord>> recPredicate,
IgnitePredicate<DataEntry> entryPredicate,
Map<T2<Integer,Integer>,T2<Integer,Long>> partStates)
Apply update from some iterator and with specific filters.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FileWALPointer
File WAL pointer.
|
| Modifier and Type | Field and Description |
|---|---|
protected IgniteBiTuple<WALPointer,WALRecord> |
AbstractWalRecordsIterator.curRec
Current record preloaded, to be returned on next()
Normally this should be not null because advance() method should already prepare some value |
| Modifier and Type | Method and Description |
|---|---|
WALPointer |
FsyncModeFileWriteAheadLogManager.log(WALRecord record)
Appends the given log entry to the write-ahead log.
|
WALPointer |
FileWriteAheadLogManager.log(WALRecord rec)
Appends the given log entry to the write-ahead log.
|
WALPointer |
FileWALPointer.next()
Pointer to the next record.
|
| Modifier and Type | Method and Description |
|---|---|
protected IgniteBiTuple<WALPointer,WALRecord> |
AbstractWalRecordsIterator.onNext() |
| Modifier and Type | Method and Description |
|---|---|
void |
FsyncModeFileWriteAheadLogManager.allowCompressionUntil(WALPointer ptr)
Gives a hint to WAL manager to compact WAL until given pointer (exclusively).
|
void |
FileWriteAheadLogManager.allowCompressionUntil(WALPointer ptr)
Gives a hint to WAL manager to compact WAL until given pointer (exclusively).
|
void |
FsyncModeFileWriteAheadLogManager.flush(WALPointer ptr,
boolean explicitFsync)
Makes sure that all log entries written to the log up until the specified pointer are actually written
to the underlying storage.
|
void |
FileWriteAheadLogManager.flush(WALPointer ptr,
boolean explicitFsync)
Makes sure that all log entries written to the log up until the specified pointer are actually written
to the underlying storage.
|
void |
FsyncModeFileWriteAheadLogManager.release(WALPointer start)
Invoke this method to release WAL history since provided pointer that was previously reserved.
|
void |
FileWriteAheadLogManager.release(WALPointer start)
Invoke this method to release WAL history since provided pointer that was previously reserved.
|
WALIterator |
FsyncModeFileWriteAheadLogManager.replay(WALPointer start)
Invoke this method to iterate over the written log entries.
|
WALIterator |
FileWriteAheadLogManager.replay(WALPointer start)
Invoke this method to iterate over the written log entries.
|
boolean |
FsyncModeFileWriteAheadLogManager.reserve(WALPointer start)
Invoke this method to reserve WAL history since provided pointer and prevent it's deletion.
|
boolean |
FileWriteAheadLogManager.reserve(WALPointer start)
Invoke this method to reserve WAL history since provided pointer and prevent it's deletion.
|
boolean |
FsyncModeFileWriteAheadLogManager.reserved(WALPointer ptr)
Checks if WAL segment is under lock or reserved
|
boolean |
FileWriteAheadLogManager.reserved(WALPointer ptr)
Checks if WAL segment is under lock or reserved
|
void |
FsyncModeFileWriteAheadLogManager.resumeLogging(WALPointer lastPtr)
Resumes logging after start.
|
void |
FileWriteAheadLogManager.resumeLogging(WALPointer lastPtr)
Resumes logging after start.
|
int |
FsyncModeFileWriteAheadLogManager.truncate(WALPointer low,
WALPointer high)
Gives a hint to WAL manager to clear entries logged before the given pointer.
|
int |
FileWriteAheadLogManager.truncate(WALPointer low,
WALPointer high)
Gives a hint to WAL manager to clear entries logged before the given pointer.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteBiPredicate<WALRecord.RecordType,WALPointer> |
RecordSerializerFactoryImpl.recordDeserializeFilter() |
| Modifier and Type | Method and Description |
|---|---|
WALRecord |
RecordV2Serializer.readRecord(FileInput in,
WALPointer expPtr)
Loads record from input
|
WALRecord |
RecordSerializer.readRecord(FileInput in,
WALPointer expPtr)
Loads record from input
|
WALRecord |
RecordV1Serializer.readRecord(FileInput in0,
WALPointer expPtr)
Loads record from input
|
| Modifier and Type | Method and Description |
|---|---|
RecordSerializerFactory |
RecordSerializerFactory.recordDeserializeFilter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> readTypeFilter)
Specifies deserialization filter.
|
RecordSerializerFactoryImpl |
RecordSerializerFactoryImpl.recordDeserializeFilter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> readTypeFilter)
Specifies deserialization filter.
|
| Constructor and Description |
|---|
RecordV1Serializer(RecordDataV1Serializer dataSerializer,
boolean writePointer,
boolean marshalledMode,
boolean skipPositionCheck,
IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordFilter)
Create an instance of V1 serializer.
|
RecordV2Serializer(RecordDataV2Serializer dataSerializer,
boolean writePointer,
boolean marshalledMode,
boolean skipPositionCheck,
IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordFilter)
Create an instance of Record V2 serializer.
|
| Modifier and Type | Method and Description |
|---|---|
WALRecord |
RecordIO.readWithHeaders(ByteBufferBackedDataInput in,
WALPointer expPtr)
Reads record data with headers from
in. |
Follow @ApacheIgnite
Ignite Fabric : ver. 2.6.0 Release Date : July 10 2018