Uses of Interface
org.apache.ignite.internal.pagemem.wal.WALPointer

Packages that use WALPointer

Package	Description
org.apache.ignite.internal.pagemem.wal
org.apache.ignite.internal.pagemem.wal.record
org.apache.ignite.internal.processors.cache	This package contain cache-related processors & persistence implementation.
org.apache.ignite.internal.processors.cache.distributed.dht.colocated
org.apache.ignite.internal.processors.cache.distributed.near
org.apache.ignite.internal.processors.cache.persistence	This package contain cache with persitence implementation.
org.apache.ignite.internal.processors.cache.persistence.checkpoint
org.apache.ignite.internal.processors.cache.persistence.wal
org.apache.ignite.internal.processors.cache.persistence.wal.filehandle
org.apache.ignite.internal.processors.cache.persistence.wal.reader
org.apache.ignite.internal.processors.cache.persistence.wal.scanner
org.apache.ignite.internal.processors.cache.persistence.wal.serializer
org.apache.ignite.internal.processors.cache.persistence.wal.serializer.io

Uses of WALPointer in org.apache.ignite.internal.pagemem.wal

Methods in org.apache.ignite.internal.pagemem.wal that return WALPointer

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.
WALPointer	WALPointer.next() Pointer to the next record.

Methods in org.apache.ignite.internal.pagemem.wal that return types with arguments of type WALPointer

Modifier and Type	Method and Description
Optional<WALPointer>	WALIterator.lastRead()

Methods in org.apache.ignite.internal.pagemem.wal with parameters of type WALPointer

Modifier and Type	Method and Description
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.notchLastCheckpointPtr(WALPointer ptr) Notifies this about latest checkpoint pointer.
WALRecord	IgniteWriteAheadLogManager.read(WALPointer ptr) Reads WAL record by the specified pointer.
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.
WALIterator	IgniteWriteAheadLogManager.replay(WALPointer start, @Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordDeserializeFilter) 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
int	IgniteWriteAheadLogManager.reserved(WALPointer low, WALPointer high) Checks if WAL segments 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.

Uses of WALPointer in org.apache.ignite.internal.pagemem.wal.record

Methods in org.apache.ignite.internal.pagemem.wal.record that return WALPointer

Modifier and Type	Method and Description
WALPointer	CheckpointRecord.checkpointMark()
WALPointer	WALRecord.position()

Methods in org.apache.ignite.internal.pagemem.wal.record with parameters of type WALPointer

Modifier and Type	Method and Description
void	WALRecord.position(WALPointer pos)

Constructors in org.apache.ignite.internal.pagemem.wal.record with parameters of type WALPointer

Constructor and Description
CheckpointRecord(UUID cpId, @Nullable WALPointer cpMark)
CheckpointRecord(UUID cpId, @Nullable WALPointer cpMark, boolean end) Constructor kept for serializer
CheckpointRecord(@Nullable WALPointer cpMark)
MarshalledRecord(WALRecord.RecordType type, WALPointer pos, ByteBuffer buf)

Uses of WALPointer in org.apache.ignite.internal.processors.cache

Methods in org.apache.ignite.internal.processors.cache that return WALPointer

Modifier and Type	Method and Description
WALPointer	GridCacheUpdateTxResult.loggedPointer()
protected WALPointer	GridCacheMapEntry.logMvccUpdate(IgniteInternalTx tx, CacheObject val, long expireTime, long updCntr, MvccSnapshot mvccVer)
protected WALPointer	GridCacheMapEntry.logTxUpdate(IgniteInternalTx tx, CacheObject val, long expireTime, long updCntr)

Uses of WALPointer in org.apache.ignite.internal.processors.cache.distributed.dht.colocated

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.colocated that return WALPointer

Modifier and Type	Method and Description
protected WALPointer	GridDhtDetachedCacheEntry.logTxUpdate(IgniteInternalTx tx, CacheObject val, long expireTime, long updCntr)

Uses of WALPointer in org.apache.ignite.internal.processors.cache.distributed.near

Methods in org.apache.ignite.internal.processors.cache.distributed.near that return WALPointer

Modifier and Type	Method and Description
protected WALPointer	GridNearCacheEntry.logTxUpdate(IgniteInternalTx tx, CacheObject val, long expireTime, long updCntr)

Uses of WALPointer in org.apache.ignite.internal.processors.cache.persistence

Fields in org.apache.ignite.internal.processors.cache.persistence declared as WALPointer

Modifier and Type	Field and Description
static WALPointer	GridCacheDatabaseSharedManager.CheckpointStatus.NULL_PTR Null WAL pointer.

Methods in org.apache.ignite.internal.processors.cache.persistence that return WALPointer

Modifier and Type	Method and Description
WALPointer	GridCacheDatabaseSharedManager.lastCheckpointMarkWalPointer()
WALPointer	IgniteCacheDatabaseSharedManager.lastCheckpointMarkWalPointer()

Methods in org.apache.ignite.internal.processors.cache.persistence with parameters of type WALPointer

Modifier and Type	Method and Description
CheckpointEntry	GridCacheDatabaseSharedManager.createCheckPointEntry(long cpTs, WALPointer ptr, UUID cpId, @Nullable CheckpointRecord rec, CheckpointEntryType type)
void	GridCacheDatabaseSharedManager.onWalTruncated(WALPointer highBound) Wal truncate callBack.

Method parameters in org.apache.ignite.internal.processors.cache.persistence with type arguments of type WALPointer

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.

Uses of WALPointer in org.apache.ignite.internal.processors.cache.persistence.checkpoint

Methods in org.apache.ignite.internal.processors.cache.persistence.checkpoint that return WALPointer

Modifier and Type	Method and Description
WALPointer	CheckpointEntry.checkpointMark()
WALPointer	CheckpointHistory.firstCheckpointPointer()
@Nullable WALPointer	CheckpointHistory.searchPartitionCounter(int grpId, int part, long partCntrSince) Tries to search for a WAL pointer for the given partition counter start.

Methods in org.apache.ignite.internal.processors.cache.persistence.checkpoint with parameters of type WALPointer

Modifier and Type	Method and Description
List<CheckpointEntry>	CheckpointHistory.onWalTruncated(WALPointer ptr) Clears checkpoint history after WAL truncation.

Constructors in org.apache.ignite.internal.processors.cache.persistence.checkpoint with parameters of type WALPointer

Constructor and Description
CheckpointEntry(long cpTs, WALPointer cpMark, UUID cpId, @Nullable Map<Integer,CacheState> cacheGrpStates) Checkpoint entry constructor.

Uses of WALPointer in org.apache.ignite.internal.processors.cache.persistence.wal

Classes in org.apache.ignite.internal.processors.cache.persistence.wal that implement WALPointer

Modifier and Type	Class and Description
class	FileWALPointer File WAL pointer.

Fields in org.apache.ignite.internal.processors.cache.persistence.wal with type parameters of type WALPointer

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

Methods in org.apache.ignite.internal.processors.cache.persistence.wal that return WALPointer

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.

Methods in org.apache.ignite.internal.processors.cache.persistence.wal that return types with arguments of type WALPointer

Modifier and Type	Method and Description
protected IgniteBiTuple<WALPointer,WALRecord>	AbstractWalRecordsIterator.advanceRecord(@Nullable AbstractWalRecordsIterator.AbstractReadFileHandle hnd) Switches to new record.
Optional<WALPointer>	AbstractWalRecordsIterator.lastRead()
protected IgniteBiTuple<WALPointer,WALRecord>	AbstractWalRecordsIterator.onNext()

Methods in org.apache.ignite.internal.processors.cache.persistence.wal with parameters of type WALPointer

Modifier and Type	Method and Description
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	FileWriteAheadLogManager.notchLastCheckpointPtr(WALPointer ptr) Notifies this about latest checkpoint pointer.
WALRecord	FileWriteAheadLogManager.read(WALPointer ptr) Reads WAL record by the specified pointer.
void	FileWriteAheadLogManager.release(WALPointer start) Invoke this method to release WAL history since provided pointer that was previously reserved.
WALIterator	FileWriteAheadLogManager.replay(WALPointer start) Invoke this method to iterate over the written log entries.
WALIterator	FileWriteAheadLogManager.replay(WALPointer start, @Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordDeserializeFilter) Invoke this method to iterate over the written log entries.
boolean	FileWriteAheadLogManager.reserve(WALPointer start) Invoke this method to reserve WAL history since provided pointer and prevent it's deletion.
boolean	FileWriteAheadLogManager.reserved(WALPointer ptr) Checks if WAL segment is under lock or reserved
int	FileWriteAheadLogManager.reserved(WALPointer low, WALPointer high) Checks if WAL segments is under lock or reserved.
void	FileWriteAheadLogManager.resumeLogging(WALPointer lastPtr) Resumes logging after start.
int	FileWriteAheadLogManager.truncate(WALPointer low, WALPointer high) Gives a hint to WAL manager to clear entries logged before the given pointer.

Uses of WALPointer in org.apache.ignite.internal.processors.cache.persistence.wal.filehandle

Methods in org.apache.ignite.internal.processors.cache.persistence.wal.filehandle that return WALPointer

Modifier and Type	Method and Description
@Nullable WALPointer	FileWriteHandle.addRecord(WALRecord rec)

Methods in org.apache.ignite.internal.processors.cache.persistence.wal.filehandle with parameters of type WALPointer

Modifier and Type	Method and Description
void	FileHandleManager.flush(WALPointer ptr, boolean explicitFsync)
void	FsyncFileHandleManagerImpl.flush(WALPointer ptr, boolean explicitFsync)
void	FileHandleManagerImpl.flush(WALPointer ptr, boolean explicitFsync)

Method parameters in org.apache.ignite.internal.processors.cache.persistence.wal.filehandle with type arguments of type WALPointer

Modifier and Type	Method and Description
FileHandleManager	FileHandleManagerFactory.build(GridCacheSharedContext cctx, DataStorageMetricsImpl metrics, boolean mmap, Supplier<WALPointer> lastWALPtr, RecordSerializer serializer, Supplier<FileWriteHandle> currHandleSupplier)

Constructor parameters in org.apache.ignite.internal.processors.cache.persistence.wal.filehandle with type arguments of type WALPointer

Constructor and Description
FileHandleManagerImpl(GridCacheSharedContext cctx, DataStorageMetricsImpl metrics, boolean mmap, Supplier<WALPointer> lastWALPtr, RecordSerializer serializer, Supplier<FileWriteHandle> currentHandleSupplier, WALMode mode, int walBufferSize, long maxWalSegmentSize, long fsyncDelay)
FsyncFileHandleManagerImpl(GridCacheSharedContext cctx, DataStorageMetricsImpl metrics, Supplier<WALPointer> ptr, RecordSerializer serializer, Supplier<FileWriteHandle> handle, WALMode mode, long maxWalSegmentSize, long fsyncDelay, int tlbSize)

Uses of WALPointer in org.apache.ignite.internal.processors.cache.persistence.wal.reader

Methods in org.apache.ignite.internal.processors.cache.persistence.wal.reader that return types with arguments of type WALPointer

Modifier and Type	Method and Description
static Predicate<IgniteBiTuple<WALPointer,WALRecord>>	WalFilters.checkpoint() Filtering all checkpoint records.
Optional<WALPointer>	FilteredWalIterator.lastRead()
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.

Method parameters in org.apache.ignite.internal.processors.cache.persistence.wal.reader with type arguments of type WALPointer

Modifier and Type	Method and Description
IgniteWalIteratorFactory.IteratorParametersBuilder	IgniteWalIteratorFactory.IteratorParametersBuilder.addFilter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> filter)
IgniteWalIteratorFactory.IteratorParametersBuilder	IgniteWalIteratorFactory.IteratorParametersBuilder.filter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> filter)

Constructor parameters in org.apache.ignite.internal.processors.cache.persistence.wal.reader with type arguments of type WALPointer

Constructor and Description
FilteredWalIterator(WALIterator walIterator, Predicate<IgniteBiTuple<WALPointer,WALRecord>> filter)

Uses of WALPointer in org.apache.ignite.internal.processors.cache.persistence.wal.scanner

Method parameters in org.apache.ignite.internal.processors.cache.persistence.wal.scanner with type arguments of type WALPointer

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.

Uses of WALPointer in org.apache.ignite.internal.processors.cache.persistence.wal.serializer

Methods in org.apache.ignite.internal.processors.cache.persistence.wal.serializer that return types with arguments of type WALPointer

Modifier and Type	Method and Description
IgniteBiPredicate<WALRecord.RecordType,WALPointer>	RecordSerializerFactoryImpl.recordDeserializeFilter()

Methods in org.apache.ignite.internal.processors.cache.persistence.wal.serializer with parameters of type WALPointer

Modifier and Type	Method and Description
WALRecord	RecordSerializer.readRecord(FileInput in, WALPointer expPtr) Loads record from input
WALRecord	RecordV1Serializer.readRecord(FileInput in0, WALPointer expPtr) Loads record from input
WALRecord	RecordV2Serializer.readRecord(FileInput in, WALPointer expPtr) Loads record from input

Method parameters in org.apache.ignite.internal.processors.cache.persistence.wal.serializer with type arguments of type WALPointer

Modifier and Type	Method and Description
RecordSerializerFactory	RecordSerializerFactory.recordDeserializeFilter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> readTypeFilter) Specifies deserialization filter.

Constructor parameters in org.apache.ignite.internal.processors.cache.persistence.wal.serializer with type arguments of type WALPointer

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.

Uses of WALPointer in org.apache.ignite.internal.processors.cache.persistence.wal.serializer.io

Methods in org.apache.ignite.internal.processors.cache.persistence.wal.serializer.io with parameters of type WALPointer

Modifier and Type	Method and Description
WALRecord	RecordIO.readWithHeaders(ByteBufferBackedDataInput in, WALPointer expPtr) Reads record data with headers from in.