| Modifier and Type | Method and Description |
|---|---|
WALRecord |
IgniteWriteAheadLogManager.read(WALPointer ptr)
Reads WAL record by the specified pointer.
|
| Modifier and Type | Method and Description |
|---|---|
WALPointer |
IgniteWriteAheadLogManager.log(WALRecord entry)
Appends the given log entry to the write-ahead log.
|
WALPointer |
IgniteWriteAheadLogManager.log(WALRecord entry,
RolloverType rolloverType)
Appends the given log entry to the write-ahead log.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CheckpointRecord
Checkpoint (begin) record
|
class |
DataRecord
Logical data record with cache operation description.
|
class |
EncryptedRecord
Encrypted record from WAL.
|
class |
ExchangeRecord
Partition map exchange WAL record.
|
class |
FilteredRecord
Special type of WAL record.
|
class |
MarshalledRecord
Special type of WAL record.
|
class |
MasterKeyChangeRecord
Deprecated.
Replaced by MasterKeyChangeRecordV2.
|
class |
MasterKeyChangeRecordV2
Logical record that stores encryption keys.
|
class |
MemoryRecoveryRecord
Marker indicates that binary memory recovery has finished.
|
class |
MetastoreDataRecord |
class |
MvccDataRecord
Logical data record with cache operation description.
|
class |
MvccTxRecord
Logical data record indented for MVCC transaction related actions.
|
class |
PageSnapshot |
class |
ReencryptionStartRecord
Logical record to restart reencryption with the latest encryption key.
|
class |
RollbackRecord
Rollback record.
|
class |
SnapshotRecord
Wal snapshot record.
|
class |
SwitchSegmentRecord
Record is needed to mark end of segment.
|
class |
TimeStampRecord
Base class for records with timeStamp.
|
class |
TxRecord
Logical data record indented for transaction (tx) related actions.
|
| Modifier and Type | Method and Description |
|---|---|
WALRecord |
WALRecord.previous() |
| Modifier and Type | Method and Description |
|---|---|
void |
WALRecord.previous(WALRecord prev) |
| Modifier and Type | Class and Description |
|---|---|
class |
DataPageInsertFragmentRecord
Insert fragment (part of big object which is bigger than page size) to data page record.
|
class |
DataPageInsertRecord
Insert into data page.
|
class |
DataPageMvccMarkUpdatedRecord
MVCC mark updated record.
|
class |
DataPageMvccUpdateNewTxStateHintRecord
MVCC update tx state hint record.
|
class |
DataPageMvccUpdateTxStateHintRecord
MVCC update tx state hint record.
|
class |
DataPageRemoveRecord |
class |
DataPageSetFreeListPageRecord |
class |
DataPageUpdateRecord
Update existing record in data page.
|
class |
FixCountRecord
Fix elements count record.
|
class |
FixLeftmostChildRecord
Fix leftmost child.
|
class |
FixRemoveId
Fix remove ID record.
|
class |
InitNewPageRecord
Initializes new page by calling
PageIO.initNewPage(long, long, int). |
class |
InnerReplaceRecord<L>
Inner replace on remove.
|
class |
InsertRecord<L>
Insert into inner or leaf page.
|
class |
MergeRecord<L>
Merge on remove.
|
class |
MetaPageAddRootRecord
New root in meta page.
|
class |
MetaPageCutRootRecord |
class |
MetaPageInitRecord |
class |
MetaPageInitRootInlineFlagsCreatedVersionRecord |
class |
MetaPageInitRootInlineRecord |
class |
MetaPageInitRootRecord
Initialize new meta page.
|
class |
MetaPageUpdateIndexDataRecord
Meta page delta record, includes encryption status data.
|
class |
MetaPageUpdateLastAllocatedIndex |
class |
MetaPageUpdateLastSuccessfulFullSnapshotId
Deprecated.
Will be removed at 3.0. See IGNITE-11139.
|
class |
MetaPageUpdateLastSuccessfulSnapshotId
Deprecated.
Will be removed at 3.0. See IGNITE-11139.
|
class |
MetaPageUpdateNextSnapshotId
Deprecated.
Will be removed at 3.0. See IGNITE-11139.
|
class |
MetaPageUpdatePartitionDataRecord |
class |
MetaPageUpdatePartitionDataRecordV2 |
class |
MetaPageUpdatePartitionDataRecordV3
Partition meta page delta record includes encryption status data.
|
class |
NewRootInitRecord<L>
Initialize new root page.
|
class |
PageDeltaRecord
Abstract page delta record.
|
class |
PageListMetaResetCountRecord
Delta record for page-list meta count reset
|
class |
PagesListAddPageRecord |
class |
PagesListInitNewPageRecord |
class |
PagesListRemovePageRecord |
class |
PagesListSetNextRecord |
class |
PagesListSetPreviousRecord |
class |
PartitionDestroyRecord |
class |
PartitionMetaStateRecord |
class |
RecycleRecord
Recycle index page.
|
class |
RemoveRecord
Remove.
|
class |
ReplaceRecord<L>
Replace.
|
class |
RotatedIdPartRecord
Rotated (when page has been recycled) id part delta record.
|
class |
SplitExistingPageRecord
Split existing page.
|
class |
SplitForwardPageRecord
Split forward page record.
|
class |
TrackingPageDeltaRecord
Delta record for updates in tracking pages
|
class |
TrackingPageRepairDeltaRecord
Record that indicates that "corrupted" flag should be removed from tracking page.
|
| Modifier and Type | Method and Description |
|---|---|
WALRecord |
GridCacheDatabaseSharedManager.RestoreBinaryState.next()
Advance iterator to the next record.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheDatabaseSharedManager.applyUpdatesOnRecovery(@Nullable WALIterator it,
IgniteBiPredicate<WALPointer,WALRecord> recPredicate,
IgnitePredicate<DataEntry> entryPredicate)
Apply update from some iterator and with specific filters.
|
| 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 |
|---|---|
protected @NotNull WALRecord |
AbstractWalRecordsIterator.postProcessRecord(@NotNull WALRecord rec)
Performs final conversions with record loaded from WAL.
|
WALRecord |
FileWriteAheadLogManager.read(WALPointer ptr)
Reads WAL record by the specified pointer.
|
| Modifier and Type | Method and Description |
|---|---|
protected IgniteBiTuple<WALPointer,WALRecord> |
AbstractWalRecordsIterator.advanceRecord(@Nullable AbstractWalRecordsIterator.AbstractReadFileHandle hnd)
Switches to new record.
|
protected IgniteBiTuple<WALPointer,WALRecord> |
AbstractWalRecordsIterator.onNext() |
| Modifier and Type | Method and Description |
|---|---|
WALPointer |
FileWriteAheadLogManager.log(WALRecord rec)
Appends the given log entry to the write-ahead log.
|
WALPointer |
FileWriteAheadLogManager.log(WALRecord rec,
RolloverType rolloverType)
Appends the given log entry to the write-ahead log.
|
protected @NotNull WALRecord |
AbstractWalRecordsIterator.postProcessRecord(@NotNull WALRecord rec)
Performs final conversions with record loaded from WAL.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable WALPointer |
FileWriteHandle.addRecord(WALRecord rec) |
| Modifier and Type | Method and Description |
|---|---|
static Predicate<IgniteBiTuple<WALPointer,WALRecord>> |
WalFilters.checkpoint()
Filtering all checkpoint records.
|
IgniteBiTuple<WALPointer,WALRecord> |
FilteredWalIterator.nextX()
This method is the same as
Iterator.next(), but allows for failure
with exception. |
static Predicate<IgniteBiTuple<WALPointer,WALRecord>> |
WalFilters.pageOwner(Set<T2<Integer,Long>> pageOwnerIds)
Filtering all records whose pageId is contained in pageOwnerIds.
|
static Predicate<IgniteBiTuple<WALPointer,WALRecord>> |
WalFilters.partitionMetaStateUpdate(Set<T2<Integer,Integer>> partsMetaupdate)
Filtering all records whose partitionId is contained in partsMetaupdate.
|
| Constructor and Description |
|---|
FilteredWalIterator(WALIterator walIterator,
Predicate<IgniteBiTuple<WALPointer,WALRecord>> filter) |
| Modifier and Type | Class and Description |
|---|---|
class |
HeaderRecord
Header record.
|
| Modifier and Type | Method and Description |
|---|---|
static String |
ScannerHandler.toStringRecord(WALRecord walRecord)
Make string from given wal record.
|
| Modifier and Type | Method and Description |
|---|---|
protected byte[] |
PrintRawToFileHandler.getBytes(IgniteBiTuple<WALPointer,WALRecord> record) |
void |
ScannerHandler.handle(IgniteBiTuple<WALPointer,WALRecord> record)
Handling one more record during iteration over WAL.
|
| Modifier and Type | Method and Description |
|---|---|
WALRecord |
RecordV2Serializer.readRecord(FileInput in,
WALPointer expPtr)
Loads record from input
|
WALRecord |
RecordV1Serializer.readRecord(FileInput in0,
WALPointer expPtr)
Loads record from input
|
WALRecord |
RecordSerializer.readRecord(FileInput in,
WALPointer expPtr)
Loads record from input
|
WALRecord |
RecordDataV1Serializer.readRecord(WALRecord.RecordType type,
ByteBufferBackedDataInput in,
int size)
Reads record data of
type from buffer in. |
WALRecord |
RecordDataSerializer.readRecord(WALRecord.RecordType type,
ByteBufferBackedDataInput in,
int size)
Reads record data of
type from buffer in. |
| Modifier and Type | Method and Description |
|---|---|
protected int |
RecordDataV2Serializer.plainSize(WALRecord rec) |
int |
RecordDataV1Serializer.size(WALRecord record)
Calculates size of record data.
|
int |
RecordV2Serializer.size(WALRecord record)
Calculates record size in byte including expected wal pointer, CRC and type field
|
int |
RecordV1Serializer.size(WALRecord record)
Calculates record size in byte including expected wal pointer, CRC and type field
|
int |
RecordSerializer.size(WALRecord record)
Calculates record size in byte including expected wal pointer, CRC and type field
|
int |
RecordDataSerializer.size(WALRecord record)
Calculates size of record data.
|
protected void |
RecordDataV2Serializer.writePlainRecord(WALRecord rec,
ByteBuffer buf)
Write
rec to buf without encryption. |
void |
RecordDataV1Serializer.writeRecord(WALRecord rec,
ByteBuffer buf)
Writes record data to buffer
buf. |
void |
RecordV2Serializer.writeRecord(WALRecord record,
ByteBuffer buf) |
void |
RecordV1Serializer.writeRecord(WALRecord rec,
ByteBuffer buf) |
void |
RecordSerializer.writeRecord(WALRecord record,
ByteBuffer buf) |
void |
RecordDataSerializer.writeRecord(WALRecord record,
ByteBuffer buf)
Writes record data to buffer
buf. |
| Modifier and Type | Method and Description |
|---|---|
WALRecord |
RecordIO.readWithHeaders(ByteBufferBackedDataInput in,
WALPointer expPtr)
Reads record data with headers from
in. |
| Modifier and Type | Method and Description |
|---|---|
int |
RecordIO.sizeWithHeaders(WALRecord record)
Calculates and returns size of record data and headers.
|
void |
RecordIO.writeWithHeaders(WALRecord record,
ByteBuffer buf)
Writes record data with headers to
buf. |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.10.0 Release Date : March 10 2021