Uses of Class
org.apache.ignite.internal.processors.cache.persistence.wal.WALPointer
-
-
Uses of WALPointer in org.apache.ignite.internal.cdc
Methods in org.apache.ignite.internal.cdc that return types with arguments of type WALPointer Modifier and Type Method Description T2<WALPointer,Integer>CdcConsumerState. loadWalState()Loads CDC consumer state from file.T2<WALPointer,Integer>WalRecordsConsumer.DataEntryIterator. state()Method parameters in org.apache.ignite.internal.cdc with type arguments of type WALPointer Modifier and Type Method Description voidCdcConsumerState. saveWal(T2<WALPointer,Integer> state)Saves WAL consumption state to file. -
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 Description WALPointerIgniteWriteAheadLogManager. 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.WALPointerIgniteWriteAheadLogManager. lastWritePointer()Get last written pointer.WALPointerIgniteWriteAheadLogManager. log(WALRecord entry)Appends the given log entry to the write-ahead log.WALPointerIgniteWriteAheadLogManager. 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 Description Optional<WALPointer>WALIterator. lastRead()Methods in org.apache.ignite.internal.pagemem.wal with parameters of type WALPointer Modifier and Type Method Description WALPointerIgniteWriteAheadLogManager. 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.voidIgniteWriteAheadLogManager. notchLastCheckpointPtr(WALPointer ptr)Notifiesthisabout latest checkpoint pointer.WALRecordIgniteWriteAheadLogManager. read(WALPointer ptr)Reads WAL record by the specified pointer.voidIgniteWriteAheadLogManager. release(WALPointer start)Invoke this method to release WAL history since provided pointer that was previously reserved.WALIteratorIgniteWriteAheadLogManager. replay(WALPointer start)Invoke this method to iterate over the written log entries.WALIteratorIgniteWriteAheadLogManager. replay(WALPointer start, @Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordDeserializeFilter)Invoke this method to iterate over the written log entries.booleanIgniteWriteAheadLogManager. reserve(WALPointer start)Invoke this method to reserve WAL history since provided pointer and prevent it's deletion.booleanIgniteWriteAheadLogManager. reserved(WALPointer ptr)Checks if WAL segment is under lock or reservedintIgniteWriteAheadLogManager. reserved(WALPointer low, WALPointer high)Checks if WAL segments is under lock or reserved.voidIgniteWriteAheadLogManager. resumeLogging(WALPointer lastWrittenPtr)Resumes logging after start.intIgniteWriteAheadLogManager. truncate(@Nullable WALPointer high)Gives a hint to WAL manager to clear entries logged before the given pointer.Method parameters in org.apache.ignite.internal.pagemem.wal with type arguments of type WALPointer Modifier and Type Method Description WALIteratorIgniteWriteAheadLogManager. replay(WALPointer start, @Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordDeserializeFilter)Invoke this method to iterate over the written log entries. -
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 Description WALPointerCheckpointRecord. checkpointMark()WALPointerWALRecord. position()Methods in org.apache.ignite.internal.pagemem.wal.record that return types with arguments of type WALPointer Modifier and Type Method Description T2<WALPointer,Integer>CdcManagerRecord. walState()Methods in org.apache.ignite.internal.pagemem.wal.record with parameters of type WALPointer Modifier and Type Method Description voidWALRecord. position(WALPointer pos)Constructors in org.apache.ignite.internal.pagemem.wal.record with parameters of type WALPointer Constructor Description CheckpointRecord(@Nullable WALPointer cpMark)CheckpointRecord(UUID cpId, @Nullable WALPointer cpMark)CheckpointRecord(UUID cpId, @Nullable WALPointer cpMark, boolean end)Constructor kept for serializerMarshalledRecord(WALRecord.RecordType type, WALPointer pos, ByteBuffer buf)Constructor parameters in org.apache.ignite.internal.pagemem.wal.record with type arguments of type WALPointer Constructor Description CdcManagerRecord(T2<WALPointer,Integer> state) -
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 Description WALPointerGridCacheUpdateTxResult. loggedPointer()protected WALPointerGridCacheMapEntry. logTxUpdate(IgniteInternalTx tx, CacheObject val, GridCacheVersion writeVer, 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 Description protected WALPointerGridDhtDetachedCacheEntry. logTxUpdate(IgniteInternalTx tx, CacheObject val, GridCacheVersion writeVer, 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 Description protected WALPointerGridNearCacheEntry. logTxUpdate(IgniteInternalTx tx, CacheObject val, GridCacheVersion writeVer, 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 Description WALPointerGridCacheDatabaseSharedManager. lastCheckpointMarkWalPointer()@Nullable WALPointerIgniteCacheDatabaseSharedManager. lastCheckpointMarkWalPointer()WALPointerGridCacheDatabaseSharedManager. latestWalPointerReservedForPreloading()Returns the latest WAL pointer that reserved for preloading ornull.WALPointerIgniteCacheDatabaseSharedManager. latestWalPointerReservedForPreloading()Returns the latest WAL pointer that reserved for preloading ornull.Methods in org.apache.ignite.internal.processors.cache.persistence with parameters of type WALPointer Modifier and Type Method Description voidGridCacheDatabaseSharedManager. onWalTruncated(@Nullable WALPointer highBound)Wal truncate callback.voidIgniteCacheDatabaseSharedManager. 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 Description voidGridCacheDatabaseSharedManager. 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 Description WALPointerCheckpointStatus. endPtrCheckpoint end pointer.static WALPointerCheckpointStatus. NULL_PTRNull WAL pointer.WALPointerCheckpointStatus. startPtrCheckpoint start pointer.Methods in org.apache.ignite.internal.processors.cache.persistence.checkpoint that return WALPointer Modifier and Type Method Description WALPointerCheckpointEntry. checkpointMark()WALPointerCheckpointHistory. firstCheckpointPointer()@Nullable WALPointerCheckpointHistoryResult. reservedCheckpointMark()Returns the oldest reserved checkpoint marker.@Nullable WALPointerCheckpointHistory. 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 Description voidCheckpointer. finalizeCheckpointOnRecovery(long cpTs, UUID cpId, WALPointer walPtr, StripedExecutor exec)voidCheckpointManager. finalizeCheckpointOnRecovery(long ts, UUID id, WALPointer ptr, StripedExecutor exec)voidCheckpointWorkflow. 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).voidLightweightCheckpointManager. finalizeCheckpointOnRecovery(long ts, UUID id, WALPointer ptr, StripedExecutor exec)voidCheckpointManager. memoryRecoveryRecordPtr(WALPointer memoryRecoveryRecordPtr)voidCheckpointWorkflow. memoryRecoveryRecordPtr(WALPointer memoryRecoveryRecordPtr)voidLightweightCheckpointManager. memoryRecoveryRecordPtr(WALPointer memoryRecoveryRecordPtr)List<CheckpointEntry>CheckpointHistory. onWalTruncated(WALPointer highBound)Clears checkpoint history after WAL truncation.voidCheckpointManager. removeCheckpointsUntil(@Nullable WALPointer highBound)Wal truncate callback.voidCheckpointMarkersStorage. removeCheckpointsUntil(@Nullable WALPointer highBound)Wal truncate callback.CheckpointEntryCheckpointMarkersStorage. writeCheckpointEntry(long cpTs, UUID cpId, WALPointer ptr, @Nullable CheckpointRecord rec, CheckpointEntryType type, boolean skipSync)Writes checkpoint entry bufferentryBufto specified checkpoint file with 2-phase protocol. -
Uses of WALPointer in org.apache.ignite.internal.processors.cache.persistence.snapshot
Methods in org.apache.ignite.internal.processors.cache.persistence.snapshot that return WALPointer Modifier and Type Method Description WALPointerIncrementalSnapshotMetadata. incrementalSnapshotPointer()@Nullable WALPointerSnapshotMetadata. snapshotRecordPointer()Constructors in org.apache.ignite.internal.processors.cache.persistence.snapshot with parameters of type WALPointer Constructor Description IncrementalSnapshotMetadata(UUID rqId, String snpName, int incIdx, String consId, String folderName, long snapshotTime, WALPointer incSnpRec)SnapshotFutureTaskResult(Set<GroupPartitionId> parts, @Nullable WALPointer snpPtr)SnapshotMetadata(UUID rqId, String snpName, String consId, String folderName, boolean comprParts, int pageSize, List<Integer> grpIds, long snapshotTime, Collection<Integer> compGrpIds, Set<String> bltNodes, Set<GroupPartitionId> pairs, @Nullable WALPointer snpRecPtr, @org.jetbrains.annotations.Nullable byte[] masterKeyDigest, boolean onlyPrimary, boolean dump, @org.jetbrains.annotations.Nullable byte[] encKey) -
Uses of WALPointer in org.apache.ignite.internal.processors.cache.persistence.wal
Fields in org.apache.ignite.internal.processors.cache.persistence.wal declared as WALPointer Modifier and Type Field Description protected @Nullable WALPointerAbstractWalRecordsIterator. highBoundOptional inclusive high bound.Fields in org.apache.ignite.internal.processors.cache.persistence.wal with type parameters of type WALPointer Modifier and Type Field Description protected IgniteBiTuple<WALPointer,WALRecord>AbstractWalRecordsIterator. curRecCurrent record preloaded, to be returned on next()
Normally this should be not null because advance() method should already prepare some valueMethods in org.apache.ignite.internal.processors.cache.persistence.wal that return WALPointer Modifier and Type Method Description WALPointerFileWriteAheadLogManager. 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.WALPointerFileWriteAheadLogManager. lastWritePointer()Get last written pointer.WALPointerFileWriteAheadLogManager. log(WALRecord rec)Appends the given log entry to the write-ahead log.WALPointerFileWriteAheadLogManager. log(WALRecord rec, RolloverType rolloverType)Appends the given log entry to the write-ahead log.WALPointerWALPointer. 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 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 Description intWALPointer. compareTo(@NotNull WALPointer o)WALPointerFileWriteAheadLogManager. 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 IgniteCheckedExceptionAbstractWalRecordsIterator. handleRecordException(@NotNull Exception e, @Nullable WALPointer ptr)Handler for record deserialization exception.protected AbstractWalRecordsIterator.AbstractReadFileHandleAbstractWalRecordsIterator. initReadHandle(@NotNull AbstractWalRecordsIterator.AbstractFileDescriptor desc, @Nullable WALPointer start)Assumes file descriptor will be opened in this method.protected AbstractWalRecordsIterator.AbstractReadFileHandleAbstractWalRecordsIterator. 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.voidFileWriteAheadLogManager. notchLastCheckpointPtr(WALPointer ptr)Notifiesthisabout latest checkpoint pointer.WALRecordFileWriteAheadLogManager. read(WALPointer ptr)Reads WAL record by the specified pointer.voidFileWriteAheadLogManager. release(WALPointer start)Invoke this method to release WAL history since provided pointer that was previously reserved.WALIteratorFileWriteAheadLogManager. replay(WALPointer start)Invoke this method to iterate over the written log entries.WALIteratorFileWriteAheadLogManager. replay(WALPointer start, @Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordDeserializeFilter)Invoke this method to iterate over the written log entries.booleanFileWriteAheadLogManager. reserve(WALPointer start)Invoke this method to reserve WAL history since provided pointer and prevent it's deletion.booleanFileWriteAheadLogManager. reserved(WALPointer ptr)Checks if WAL segment is under lock or reservedintFileWriteAheadLogManager. reserved(WALPointer low, WALPointer high)Checks if WAL segments is under lock or reserved.voidFileWriteAheadLogManager. resumeLogging(WALPointer filePtr)Resumes logging after start.intFileWriteAheadLogManager. truncate(@Nullable WALPointer high)Gives a hint to WAL manager to clear entries logged before the given pointer.Method parameters in org.apache.ignite.internal.processors.cache.persistence.wal with type arguments of type WALPointer Modifier and Type Method Description WALIteratorFileWriteAheadLogManager. replay(WALPointer start, @Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> recordDeserializeFilter)Invoke this method to iterate over the written log entries.Constructors in org.apache.ignite.internal.processors.cache.persistence.wal with parameters of type WALPointer Constructor Description AbstractWalRecordsIterator(@NotNull IgniteLogger log, @NotNull GridCacheSharedContext sharedCtx, @NotNull RecordSerializerFactory serializerFactory, @NotNull FileIOFactory ioFactory, int initialReadBufferSize, @Nullable WALPointer highBound, SegmentFileInputFactory segmentFileInputFactory) -
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 Description @Nullable WALPointerFileWriteHandle. addRecord(WALRecord rec)WALPointerFileHandleManager. flush(WALPointer ptr, boolean explicitFsync)WALPointerFileHandleManagerImpl. flush(WALPointer ptr, boolean explicitFsync)WALPointerFsyncFileHandleManagerImpl. flush(WALPointer ptr, boolean explicitFsync)WALPointerFileWriteHandle. position()Methods in org.apache.ignite.internal.processors.cache.persistence.wal.filehandle with parameters of type WALPointer Modifier and Type Method Description WALPointerFileHandleManager. flush(WALPointer ptr, boolean explicitFsync)WALPointerFileHandleManagerImpl. flush(WALPointer ptr, boolean explicitFsync)WALPointerFsyncFileHandleManagerImpl. flush(WALPointer ptr, boolean explicitFsync)voidFileWriteHandle. fsync(WALPointer ptr)Do fsync.booleanFileWriteHandle. 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 Description static WALPointerIgniteWalIteratorFactory.IteratorParametersBuilder. DFLT_HIGH_BOUNDstatic WALPointerIgniteWalIteratorFactory.IteratorParametersBuilder. DFLT_LOW_BOUNDMethods in org.apache.ignite.internal.processors.cache.persistence.wal.reader that return types with arguments of type WALPointer Modifier and Type Method 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 asIterator.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 Description IgniteWalIteratorFactory.IteratorParametersBuilderIgniteWalIteratorFactory.IteratorParametersBuilder. from(WALPointer lowBound)WALIteratorIgniteWalIteratorFactory. iterator(@NotNull WALPointer replayFrom, @NotNull File... filesOrDirs)Creates iterator for file by file scan mode.WALIteratorIgniteWalIteratorFactory. iterator(@NotNull WALPointer replayFrom, @NotNull String... filesOrDirs)Creates iterator for file by file scan mode.IgniteWalIteratorFactory.IteratorParametersBuilderIgniteWalIteratorFactory.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 Description IgniteWalIteratorFactory.IteratorParametersBuilderIgniteWalIteratorFactory.IteratorParametersBuilder. addFilter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> filter)IgniteWalIteratorFactory.IteratorParametersBuilderIgniteWalIteratorFactory.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 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 Description protected byte[]PrintRawToFileHandler. getBytes(IgniteBiTuple<WALPointer,WALRecord> record)voidScannerHandler. 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 Description static WALPointerRecordV1Serializer. 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 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 Description static voidRecordV1Serializer. putPosition(ByteBuffer buf, WALPointer ptr)Saves position, WAL pointer (requiresRecordV1Serializer.FILE_WAL_POINTER_SIZEbytes)WALRecordRecordSerializer. readRecord(FileInput in, WALPointer expPtr)Loads record from inputWALRecordRecordV1Serializer. readRecord(FileInput in0, WALPointer expPtr)Loads record from inputWALRecordRecordV2Serializer. readRecord(FileInput in, WALPointer expPtr)Loads record from inputMethod parameters in org.apache.ignite.internal.processors.cache.persistence.wal.serializer with type arguments of type WALPointer Modifier and Type Method Description RecordSerializerFactoryRecordSerializerFactory. recordDeserializeFilter(IgniteBiPredicate<WALRecord.RecordType,WALPointer> readTypeFilter)Specifies deserialization filter.RecordSerializerFactoryImplRecordSerializerFactoryImpl. recordDeserializeFilter(@Nullable 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 Description RecordSerializerFactoryImpl(GridCacheSharedContext cctx, @Nullable IgniteBiPredicate<WALRecord.RecordType,WALPointer> readTypeFilter)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 Description WALRecordRecordIO. readWithHeaders(ByteBufferBackedDataInput in, WALPointer expPtr)Reads record data with headers fromin.
-