Uses of Class
org.apache.ignite.internal.processors.cache.persistence.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 persistence 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.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.
WALPointer	IgniteWriteAheadLogManager.lastWritePointer() Get last written pointer.
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.

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
WALPointer	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(@Nullable 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

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

Modifier and Type	Method and Description
WALPointer	GridCacheDatabaseSharedManager.lastCheckpointMarkWalPointer()
@Nullable WALPointer	IgniteCacheDatabaseSharedManager.lastCheckpointMarkWalPointer()
WALPointer	GridCacheDatabaseSharedManager.latestWalPointerReservedForPreloading() Returns the latest WAL pointer that reserved for preloading or null.
WALPointer	IgniteCacheDatabaseSharedManager.latestWalPointerReservedForPreloading() Returns the latest WAL pointer that reserved for preloading or null.

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

Modifier and Type	Method and Description
void	GridCacheDatabaseSharedManager.onWalTruncated(@Nullable 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

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

Modifier and Type	Field and Description
WALPointer	CheckpointStatus.endPtr Checkpoint end pointer.
static WALPointer	CheckpointStatus.NULL_PTR Null WAL pointer.
WALPointer	CheckpointStatus.startPtr Checkpoint start pointer.

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.searchEarliestWalPointer(int grpId, Map<Integer,Long> partsCounter, long margin) Search the earliest WAL pointer for particular group, matching by counter for partitions.

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

Modifier and Type	Method and Description
void	CheckpointManager.finalizeCheckpointOnRecovery(long ts, UUID id, WALPointer ptr, StripedExecutor exec)
void	LightweightCheckpointManager.finalizeCheckpointOnRecovery(long ts, UUID id, WALPointer ptr, StripedExecutor exec)
void	Checkpointer.finalizeCheckpointOnRecovery(long cpTs, UUID cpId, WALPointer walPtr, StripedExecutor exec)
void	CheckpointWorkflow.finalizeCheckpointOnRecovery(long cpTs, UUID cpId, WALPointer walPtr, StripedExecutor exec, CheckpointPagesWriterFactory checkpointPagesWriterFactory) This method makes sense if node was stopped during the checkpoint(Start marker was written to disk while end marker are not).
void	CheckpointManager.memoryRecoveryRecordPtr(WALPointer memoryRecoveryRecordPtr)
void	LightweightCheckpointManager.memoryRecoveryRecordPtr(WALPointer memoryRecoveryRecordPtr)
void	CheckpointWorkflow.memoryRecoveryRecordPtr(WALPointer memoryRecoveryRecordPtr)
List<CheckpointEntry>	CheckpointHistory.onWalTruncated(WALPointer highBound) Clears checkpoint history after WAL truncation.
void	CheckpointManager.removeCheckpointsUntil(@Nullable WALPointer highBound) Wal truncate callback.
void	CheckpointMarkersStorage.removeCheckpointsUntil(@Nullable WALPointer highBound) Wal truncate callback.
CheckpointEntry	CheckpointMarkersStorage.writeCheckpointEntry(long cpTs, UUID cpId, WALPointer ptr, @Nullable CheckpointRecord rec, CheckpointEntryType type, boolean skipSync) Writes checkpoint entry buffer entryBuf to specified checkpoint file with 2-phase protocol.

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

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.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.
WALPointer	FileWriteAheadLogManager.lastWritePointer() Get last written pointer.
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.
WALPointer	WALPointer.next() Pointer to the next record.

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
int	WALPointer.compareTo(@NotNull WALPointer o)
WALPointer	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.
Collection<File>	FileWriteAheadLogManager.getWalFilesFromArchive(WALPointer low, WALPointer high) Collects WAL segments from the archive only if they are all present.
protected IgniteCheckedException	AbstractWalRecordsIterator.handleRecordException(@NotNull Exception e, @Nullable WALPointer ptr) Handler for record deserialization exception.
protected AbstractWalRecordsIterator.AbstractReadFileHandle	AbstractWalRecordsIterator.initReadHandle(@NotNull AbstractWalRecordsIterator.AbstractFileDescriptor desc, @Nullable WALPointer start) Assumes file descriptor will be opened in this method.
protected AbstractWalRecordsIterator.AbstractReadFileHandle	AbstractWalRecordsIterator.initReadHandle(@NotNull AbstractWalRecordsIterator.AbstractFileDescriptor desc, @Nullable WALPointer start, @NotNull SegmentIO fileIO, @NotNull SegmentHeader segmentHeader) Assumes fileIO will be closed in this method in case of error occurred.
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 filePtr) Resumes logging after start.
int	FileWriteAheadLogManager.truncate(@Nullable 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)
WALPointer	FsyncFileHandleManagerImpl.flush(WALPointer ptr, boolean explicitFsync)
WALPointer	FileHandleManagerImpl.flush(WALPointer ptr, boolean explicitFsync)
WALPointer	FileHandleManager.flush(WALPointer ptr, boolean explicitFsync)
WALPointer	FileWriteHandle.position()

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

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

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

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

Modifier and Type	Field and Description
static WALPointer	IgniteWalIteratorFactory.IteratorParametersBuilder.DFLT_HIGH_BOUND
static WALPointer	IgniteWalIteratorFactory.IteratorParametersBuilder.DFLT_LOW_BOUND

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.

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

Modifier and Type	Method and Description
IgniteWalIteratorFactory.IteratorParametersBuilder	IgniteWalIteratorFactory.IteratorParametersBuilder.from(WALPointer lowBound)
WALIterator	IgniteWalIteratorFactory.iterator(@NotNull WALPointer replayFrom, File... filesOrDirs) Creates iterator for file by file scan mode.
WALIterator	IgniteWalIteratorFactory.iterator(@NotNull WALPointer replayFrom, String... filesOrDirs) Creates iterator for file by file scan mode.
IgniteWalIteratorFactory.IteratorParametersBuilder	IgniteWalIteratorFactory.IteratorParametersBuilder.to(WALPointer highBound)

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 WALPointer

Modifier and Type	Method and Description
static WALPointer	RecordV1Serializer.readPosition(DataInput in)

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
static void	RecordV1Serializer.putPosition(ByteBuffer buf, WALPointer ptr) Saves position, WAL pointer (requires RecordV1Serializer.FILE_WAL_POINTER_SIZE bytes)
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

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.