Uses of Class
org.apache.ignite.IgniteCheckedException
Packages that use IgniteCheckedException
Package
Description
-
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.backreference
Methods in com._1c.g5.v8.bm.core.internal.backreference that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidBackReferenceStoreTest.setUp()voidBackReferenceStoreTest.testSnapshots() -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.blob
Methods in com._1c.g5.v8.bm.core.internal.blob that throw IgniteCheckedException -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.id
Methods in com._1c.g5.v8.bm.core.internal.id that throw IgniteCheckedException -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.ignite
Methods in com._1c.g5.v8.bm.core.internal.ignite that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionStoreManager.connectExternalBinaryLongIndexRowStore(String name, String dataRegionName, Path storeDataPath) StoreManager.connectExternalContainedObjectIndexRowStore(String name, String dataRegionName, Path storeDataPath) StoreManager.connectExternalIntIntIndexRowStore(String name, String dataRegionName, Path storeDataPath) StoreManager.connectExternalLongKeyValueStore(String name, String dataRegionName, Class<?> valueType, Path storeDataPath) StoreManager.connectExternalObjectKeyValueStore(String name, String dataRegionName, Class<?> keyType, Class<?> valueType, Path storeDataPath) StoreManager.createBinaryLongIndexRowStore(String name, String dataRegionName) StoreManager.createBinaryLongIndexRowStoreFromSnapshot(String name, String dataRegionName, InputStream in) StoreManager.createContainedObjectIndexRowStore(String name, String dataRegionName) StoreManager.createContainedObjectIndexRowStoreFromSnapshot(String name, String dataRegionName, InputStream in) StoreManager.createIntIntIndexRowStore(String name, String dataRegionName) StoreManager.createIntIntIndexRowStoreFromSnapshot(String name, String dataRegionName, InputStream in) StoreManager.createLongKeyValueStore(String name, String dataRegionName, Class<?> valueType) StoreManager.createLongKeyValueStoreFromSnapshot(String name, String dataRegionName, Class<?> valueType, InputStream in) StoreManager.createObjectKeyValueStore(String name, String dataRegionName, Class<?> keyType, Class<?> valueType) StoreManager.createObjectKeyValueStoreFromSnapshot(String name, String dataRegionName, Class<?> keyType, Class<?> valueType, InputStream in) LongKeyValueStore.cursor()ObjectKeyValueStore.cursor()voidStoreManager.deleteKeyValueStore(String name) voidStoreManager.exportStore(String name, Path destinationPath) LongKeyValueStore.get(long key) IndexRowStore.getAllRows()LongKeyValueStore.getAndRemove(long key) ObjectKeyValueStore.getAndRemove(Object key) IndexRowStore.getRowsSparse(Function<R, R> lowerBoundSupplier) voidStoreManager.prepareForCheckpoint()voidvoidvoidLongKeyValueStore.remove(long key) voidvoidStoreManager.saveStoreSnapshot(String name, OutputStream out) voidStoreManager.start()voidStoreManager.startPageStores(boolean restorationMode) -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.ignite.infrastructure
Methods in com._1c.g5.v8.bm.core.internal.ignite.infrastructure that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidInternalKeyValueStore.beforeCheckpoint()TODO JavaDocvoidDataRegionManager.start() -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.ignite.itests
Methods in com._1c.g5.v8.bm.core.internal.ignite.itests that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidLongKeyValueStoreBasicTest.testCursor()voidLongKeyValueStoreBasicTest.testCursorWorksCorrectlyWhenLeafNodeDeletedAndPageReused()voidObjectKeyValueStoreBasicTest.testEntryIterator()voidLongKeyValueStoreBasicTest.testGetAndRemove()voidObjectKeyValueStoreBasicTest.testGetAndRemove()voidLongKeyValueStoreBasicTest.testPut()voidObjectKeyValueStoreBasicTest.testPut()voidLongKeyValueStoreBasicTest.testRemove()voidObjectKeyValueStoreBasicTest.testRemove()voidStoreManagementTest.testRestartAfterCreateStore()voidStoreManagementTest.testRestartAfterDeleteKeyValueStore()voidStoreManagementTest.testRestartAfterDeleteKeyValueStoreInterrupted()voidStoreManagementTest.testRestartAfterDirectoryMoved()voidRestorationTest.testRestartAfterInterruptedCheckpoint() -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.ignite.marshaller
Methods in com._1c.g5.v8.bm.core.internal.ignite.marshaller that throw IgniteCheckedException -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.ignite.store.index
Methods in com._1c.g5.v8.bm.core.internal.ignite.store.index that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionprotected intintIndexRowComparator.compareKeys(A access, long pageAddr, int off, R row) intIndexRowComparator.compareValues(A access, long pageAddr, int off, R row) JumpingIndexCursor.get()SafeCursorDecorator.get()IndexRowInnerIO.getLookupRow(BPlusTree<R, ?> tree, long pageAddr, int idx) IndexRowLeafIO.getLookupRow(BPlusTree<R, ?> tree, long pageAddr, int idx) booleanJumpingIndexCursor.next()booleanSafeCursorDecorator.next()voidvoidvoidvoidIndexRowInnerIO.storeByOffset(long pageAddr, int off, R row) voidIndexRowLeafIO.storeByOffset(long pageAddr, int off, R row) Constructors in com._1c.g5.v8.bm.core.internal.ignite.store.index that throw IgniteCheckedExceptionModifierConstructorDescriptionIndexDataTree(String name, int cacheGrpId, int pageSize, boolean initNew, PageMemory pageMem, WalManager wal, org.apache.ignite.internal.PageAccessHelper pageHandler, AtomicLong globalRmvId, long metaPageId, ReuseList reuseList, IOVersions<? extends BPlusInnerIO<R>> innerIos, IOVersions<? extends BPlusLeafIO<R>> leafIos, IndexRowComparator<R, A> rowComparator, org.apache.ignite.internal.FailureProcessor failureProcessor, PageLockListener lockLsnr) -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.ignite.store.index.binary
Methods in com._1c.g5.v8.bm.core.internal.ignite.store.index.binary that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidBinaryDataStore.load(BinaryData storable) voidBinaryDataStoreImpl.load(BinaryData storable) protected voidBinaryDataIO.printPage(long addr, int pageSize, GridStringBuilder sb) voidBinaryDataStore.remove(BinaryData storable) voidBinaryDataStoreImpl.remove(BinaryData storable) intBinaryData.size()voidBinaryDataStore.store(BinaryData storable) voidBinaryDataStoreImpl.store(BinaryData storable) protected voidBinaryDataIO.writeFragmentData(BinaryData row, ByteBuffer buf, int rowOff, int payloadSize) protected voidBinaryDataIO.writeRowData(long pageAddr, int dataOff, int payloadSize, BinaryData row, boolean newRow) -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.ignite.store.index.binarylong
Methods in com._1c.g5.v8.bm.core.internal.ignite.store.index.binarylong that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidBinaryLongIndexRowStore.beforeCheckpoint()intBinaryLongTreeRowComparator.compareKeys(BinaryLongTreeRowAccess access, long pageAddr, int off, BinaryLongTreeRow row) BinaryLongIndexRowStore.getAllRows()BinaryLongIndexRowStore.getRow(BinaryLongIndexRow lookupRow) BinaryLongIndexRowStore.getRows(BinaryLongIndexRow lower, BinaryLongIndexRow upper) BinaryLongIndexRowStore.put(BinaryLongIndexRow newRow) BinaryLongIndexRowStore.remove(BinaryLongIndexRow indexRow) voidBinaryLongIndexRowStoreTest.setUp()voidBinaryLongIndexRowStoreTest.tearDown()voidBinaryLongIndexRowStoreTest.testRemoveDataAndIterateConcurrently() -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.ignite.store.index.containment
Methods in com._1c.g5.v8.bm.core.internal.ignite.store.index.containment that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidContainedObjectIndexRowStore.beforeCheckpoint()ContainedObjectIndexRowStore.getAllRows()ContainedObjectIndexRowStore.getRow(ContainedObjectIndexRow lookupRow) ContainedObjectIndexRowStore.getRows(ContainedObjectIndexRow lower, ContainedObjectIndexRow upper) ContainedObjectIndexRowStore.put(ContainedObjectIndexRow newRow) ContainedObjectIndexRowStore.remove(ContainedObjectIndexRow row) -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.ignite.store.index.intint
Methods in com._1c.g5.v8.bm.core.internal.ignite.store.index.intint that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidIntIntIndexRowStore.beforeCheckpoint()IntIntIndexRowStore.getAllRows()IntIntIndexRowStore.getRow(IntIntIndexRow lookupRow) IntIntIndexRowStore.getRows(IntIntIndexRow lower, IntIntIndexRow upper) IntIntIndexRowStore.put(IntIntIndexRow newRow) IntIntIndexRowStore.remove(IntIntIndexRow row) -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.ignite.store.longkey
Methods in com._1c.g5.v8.bm.core.internal.ignite.store.longkey that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidLongRowStore.addRow(com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongDataRow row, IoStatisticsHolder statHolder) voidLongRowStore.addRows(Collection<com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongDataRow> rows, IoStatisticsHolder statHolder) voidLongKeyValueStoreImpl.beforeCheckpoint()protected intLongKeyDataTree.compare(BPlusIO<com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongSearchRow> iox, long pageAddr, int idx, com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongSearchRow row) LongKeyValueStoreImpl.cursor()GridCursor<com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongDataRow>LongKeyDataTree.find(com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongSearchRow lower, com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongSearchRow upper, BPlusTree.TreeRowClosure<com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongSearchRow, com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongDataRow> c, Object x) LongKeyValueStoreImpl.get(long key) LongKeyValueStoreImpl.getAndRemove(long key) final com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongSearchRowLongDataInnerIO.getLookupRow(BPlusTree<com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongSearchRow, ?> tree, long pageAddr, int idx) final com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongSearchRowLongDataLeafIO.getLookupRow(BPlusTree<com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongSearchRow, ?> tree, long pageAddr, int idx) com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongDataRowLongKeyDataTree.getRow(BPlusIO<com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongSearchRow> io, long pageAddr, int idx, Object flags) protected voidLongDataPageIO.printPage(long addr, int pageSize, GridStringBuilder sb) voidvoidLongKeyValueStoreImpl.remove(long key) voidLongRowStore.removeRow(long link, IoStatisticsHolder statHolder) <S,R> void LongRowStore.updateDataRow(long link, org.apache.ignite.internal.PageHandler<S, R> pageHnd, S arg, IoStatisticsHolder statHolder) Run page handler operation over the row.booleanLongRowStore.updateRow(long link, com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongDataRow row, IoStatisticsHolder statHolder) protected voidLongDataPageIO.writeFragmentData(com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongDataRow row, ByteBuffer buf, int rowOff, int payloadSize) protected voidLongDataPageIO.writeRowData(long pageAddr, int dataOff, int payloadSize, com._1c.g5.v8.bm.core.internal.ignite.store.longkey.LongDataRow row, boolean newRow) Constructors in com._1c.g5.v8.bm.core.internal.ignite.store.longkey that throw IgniteCheckedExceptionModifierConstructorDescriptionLongKeyDataTree(String name, int cacheGrpId, int pageSize, boolean initNew, PageMemory pageMem, WalManager wal, org.apache.ignite.internal.PageAccessHelper pageHandler, AtomicLong globalRmvId, long metaPageId, ReuseList reuseList, org.apache.ignite.internal.FailureProcessor failureProcessor, PageLockListener lockLsnr, LongRowStore rowStore) -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.ignite.store.objectkey
Methods in com._1c.g5.v8.bm.core.internal.ignite.store.objectkey that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidObjectRowStore.addRow(com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectDataRow row, IoStatisticsHolder statHolder) voidObjectRowStore.addRows(Collection<com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectDataRow> rows, IoStatisticsHolder statHolder) voidObjectKeyValueStoreImpl.beforeCheckpoint()protected intObjectKeyDataTree.compare(BPlusIO<com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectSearchRow> iox, long pageAddr, int idx, com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectSearchRow row) ObjectKeyValueStoreImpl.cursor()GridCursor<com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectDataRow>ObjectKeyDataTree.find(com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectSearchRow lower, com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectSearchRow upper, BPlusTree.TreeRowClosure<com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectSearchRow, com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectDataRow> c, Object x) ObjectKeyValueStoreImpl.getAndRemove(Object key) final com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectSearchRowObjectDataInnerIO.getLookupRow(BPlusTree<com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectSearchRow, ?> tree, long pageAddr, int idx) final com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectSearchRowObjectDataLeafIO.getLookupRow(BPlusTree<com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectSearchRow, ?> tree, long pageAddr, int idx) com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectDataRowObjectKeyDataTree.getRow(BPlusIO<com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectSearchRow> io, long pageAddr, int idx, Object flags) protected voidObjectDataPageIO.printPage(long addr, int pageSize, GridStringBuilder sb) voidvoidvoidObjectRowStore.removeRow(long link, IoStatisticsHolder statHolder) <S,R> void ObjectRowStore.updateDataRow(long link, org.apache.ignite.internal.PageHandler<S, R> pageHnd, S arg, IoStatisticsHolder statHolder) Run page handler operation over the row.booleanObjectRowStore.updateRow(long link, com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectDataRow row, IoStatisticsHolder statHolder) protected voidObjectDataPageIO.writeFragmentData(com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectDataRow row, ByteBuffer buf, int rowOff, int payloadSize) protected voidObjectDataPageIO.writeRowData(long pageAddr, int dataOff, int payloadSize, com._1c.g5.v8.bm.core.internal.ignite.store.objectkey.ObjectDataRow row, boolean newRow) Constructors in com._1c.g5.v8.bm.core.internal.ignite.store.objectkey that throw IgniteCheckedExceptionModifierConstructorDescriptionObjectKeyDataTree(String name, int cacheGrpId, int pageSize, boolean initNew, PageMemory pageMemory, WalManager wal, org.apache.ignite.internal.PageAccessHelper pageAccessHelper, ReuseList reuseList, PageStoreManager pageStoreManager, ObjectRowStore rowStore, StoreContext storeContext, long metaPageId, org.apache.ignite.internal.FailureProcessor failureProcessor, PageLockListener lockLsnr, AtomicLong globalRmvId) -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.ignite.wal
Methods in com._1c.g5.v8.bm.core.internal.ignite.wal that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidLogicalOperationExecutor.executeOperation(Object descriptor) -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.index
Methods in com._1c.g5.v8.bm.core.internal.index that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidContainedObjectIndexStoreTest.testSnapshots()voidObjectIndexStoreTest.testSnapshots()voidTopObjectIndexStoreTest.testSnapshots() -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.naming
Methods in com._1c.g5.v8.bm.core.internal.naming that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidFqnRegistryStoreTest.testCreateExternallyStoredVersionThenLoadExternallyStoredVersion()voidLowerCaseFqnMappingStoreTest.testCreateExternallyStoredVersionThenLoadExternallyStoredVersion()voidReverseFqnRegistryStoreTest.testCreateExternallyStoredVersionThenLoadExternallyStoredVersion()voidFqnMappingStoreTest.testSnapshots()voidFqnRegistryStoreTest.testSnapshots()voidLowerCaseFqnMappingStoreTest.testSnapshots()voidReverseFqnRegistryStoreTest.testSnapshots() -
Uses of IgniteCheckedException in com._1c.g5.v8.bm.core.internal.object
Methods in com._1c.g5.v8.bm.core.internal.object that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidObjectDataStoreTest.setUp()voidObjectDataStoreTest.tearDown()voidObjectDataStoreTest.testSnapshots() -
Uses of IgniteCheckedException in org.apache.ignite.internal
Subclasses of IgniteCheckedException in org.apache.ignite.internalModifier and TypeClassDescriptionclassorg.apache.ignite.internal.CorruptedDataStructureExceptionAbstract exception whenDataStructureare corrupted. -
Uses of IgniteCheckedException in org.apache.ignite.internal.pagemem
Methods in org.apache.ignite.internal.pagemem that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionlongPageMemory.acquirePage(int grpId, int pageId, int tag) Gets the page absolute pointer associated with the given page ID.longPageMemory.acquirePage(int grpId, int pageId, int tag, boolean restore) Gets the page absolute pointer associated with the given page ID.longPageMemoryImpl.acquirePage(int grpId, int pageId, int tag) longPageMemoryImpl.acquirePage(int grpId, int pageId, int tag, boolean restore) intPageMemory.allocatePage(int grpId, int tag) Allocates a page from the space for the given partition ID and the given flags.intPageMemoryImpl.allocatePage(int grpId, int tag) intPageStoreManager.allocatePage(int grpId) Allocates a page for the given page space.voidPageStoreManager.exportStore(int grpId, Path destinationPath) Exports the store.voidPageStoreManagerImpl.exportStore(int grpId, Path destinationPath) booleanPageStoreManager.isMetaPagePersisted(int grpId) Checks if meta page for specified store is persisted.booleanPageStoreManagerImpl.isMetaPagePersisted(int grpId) intPageMemory.metaPageId(int grpId) Gets or allocates metadata page for specified grpId.voidPageStoreManager.read(int grpId, int pageId, ByteBuffer pageBuf) Reads a page for the given group ID.voidPageStoreManagerImpl.read(int grpId, int pageId, ByteBuffer pageBuf) voidPageMemory.reduceMemoryFootprint()Reduces memory footprint.voidPageMemoryImpl.reduceMemoryFootprint()voidPageStoreManager.reservePage(int grpId, int pageId) Reserves a page.voidPageStoreManagerImpl.reservePage(int grpId, int pageId) voidPageMemory.runCheckpoint()Runs a checkpoint.voidPageMemoryImpl.runCheckpoint()voidPageMemory.start()Start page memory.voidPageMemoryImpl.start()voidPageMemory.startStore(int grpId, int metaPageTag, Path path, boolean restorationMode) Starts the store with the specified ID.voidPageMemoryImpl.startStore(int grpId, int metaPageTag, Path path, boolean restorationMode) voidPageStoreManager.startStore(int grpId, Path path, boolean restorationMode) Starts the store with the specified ID.voidPageStoreManagerImpl.startStore(int grpId, Path path, boolean restorationMode) voidPageMemory.stop()Stop page memory.voidPageMemoryImpl.stop()voidPageMemory.stopStore(int grpId, boolean freePages) Stops the store with the specified ID.voidPageMemoryImpl.stopStore(int grpId, boolean freePages) voidPageStoreManager.stopStore(int grpId) Stops the store with the specified ID.voidPageStoreManagerImpl.stopStore(int grpId) voidPageStoreManager.write(int grpId, int pageId, ByteBuffer pageBuf) Writes the page for the given group ID.voidPageStoreManagerImpl.write(int grpId, int pageId, ByteBuffer pageBuf) -
Uses of IgniteCheckedException in org.apache.ignite.internal.persistence.checkpoint
Methods in org.apache.ignite.internal.persistence.checkpoint that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionCheckpointer.getCheckpointRequirementLevel()Gets checkpoint requirement level.CheckpointerImpl.getCheckpointRequirementLevel()voidCheckpointer.runCheckpoint()Runs checkpoint.voidCheckpointerImpl.runCheckpoint() -
Uses of IgniteCheckedException in org.apache.ignite.internal.persistence.freelist
Subclasses of IgniteCheckedException in org.apache.ignite.internal.persistence.freelistMethods in org.apache.ignite.internal.persistence.freelist that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidFreeListImpl.addForRecycle(ReuseBag bag) protected final voidPagesList.init(long metaPageId, boolean initNew) longFreeListImpl.initRecycledPage(long pageId, byte flag, PageIO initIO) Converts recycled page id back to a usable id.protected longPagesList.initRecycledPage0(long pageId, byte flag, PageIO initIO) Create new page id and update page content accordingly if it's necessary.protected final longPagesList.initReusedPage(long reusedPageId, long reusedPage, long reusedPageAddr, byte flag, PageIO initIo) Reused page must obtain correctly assembled page id, then initialized by properPageIOinstance and non-zeroitemIdof reused page id must be saved into special place.voidFreeList.insertDataRow(org.apache.ignite.internal.Storable row, IoStatisticsHolder statHolder) voidFreeListImpl.insertDataRow(org.apache.ignite.internal.Storable row, IoStatisticsHolder statHolder) voidFreeList.insertDataRows(Collection<? extends org.apache.ignite.internal.Storable> rows, IoStatisticsHolder statHolder) voidFreeListImpl.insertDataRows(Collection<? extends org.apache.ignite.internal.Storable> rows, IoStatisticsHolder statHolder) Reduces the workload on the free list by writing multiple rows into a single memory page at once.
Rows are sequentially added to the page as long as there is enough free space on it.protected final voidPagesList.put(ReuseBag bag, long dataId, long dataPage, long dataAddr, int bucket, IoStatisticsHolder statHolder) longFreeListImpl.recycledPagesCount()protected final booleanPagesList.removeDataPage(long dataId, long dataPage, long dataAddr, AbstractDataPageIO dataIO, int bucket, IoStatisticsHolder statHolder) Removes data page from bucket, merges bucket list if needed.voidFreeList.removeDataRowByLink(long link, IoStatisticsHolder statHolder) voidFreeListImpl.removeDataRowByLink(long link, IoStatisticsHolder statHolder) voidPagesList.saveMetadata(IoStatisticsHolder statHolder) Save metadata without exclusive lock on it.intSimpleDataRow.size()protected final longPagesList.storedPagesCount(int bucket) !!!protected longPagesList.takeEmptyPage(int bucket, IOVersions initIoVers, IoStatisticsHolder statHolder) longFreeListImpl.takeRecycledPage()<S,R> R FreeList.updateDataRow(long link, org.apache.ignite.internal.PageHandler<S, R> pageHnd, S arg, IoStatisticsHolder statHolder) booleanFreeList.updateDataRow(long link, org.apache.ignite.internal.Storable row, IoStatisticsHolder statHolder) <S,R> R FreeListImpl.updateDataRow(long link, org.apache.ignite.internal.PageHandler<S, R> pageHnd, S arg, IoStatisticsHolder statHolder) booleanFreeListImpl.updateDataRow(long link, org.apache.ignite.internal.Storable row, IoStatisticsHolder statHolder) Constructors in org.apache.ignite.internal.persistence.freelist that throw IgniteCheckedExceptionModifierConstructorDescriptionFreeListImpl(int cacheId, String name, int pageSize, DataRegionMetrics memMetrics, PageMemory pageMemory, ReuseList reuseList, WalManager wal, org.apache.ignite.internal.PageAccessHelper pageHandler, long metaPageId, boolean initNew, PageLockListener lockLsnr, IgniteLogger log, AtomicLong pageListCacheLimit) -
Uses of IgniteCheckedException in org.apache.ignite.internal.persistence.freelist.io
Methods in org.apache.ignite.internal.persistence.freelist.io that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionprotected voidPagesListMetaIO.printPage(long addr, int pageSize, GridStringBuilder sb) protected voidPagesListNodeIO.printPage(long addr, int pageSize, GridStringBuilder sb) -
Uses of IgniteCheckedException in org.apache.ignite.internal.persistence.metastorage
Methods in org.apache.ignite.internal.persistence.metastorage that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidMetaStorage.saveMetadata(IoStatisticsHolder statHolder) Save metadata without exclusive lock on it. -
Uses of IgniteCheckedException in org.apache.ignite.internal.persistence.store
Methods in org.apache.ignite.internal.persistence.store that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidStoreObject.finishUnmarshal(StoreContext ctx, ClassLoader ldr) voidStoreObjectImpl.finishUnmarshal(StoreContext ctx, ClassLoader ldr) voidStoreObject.prepareMarshal(StoreContext ctx) voidStoreObjectImpl.prepareMarshal(StoreContext ctx) intStoreObject.putValue(long addr) booleanStoreObject.putValue(ByteBuffer buf) booleanStoreObject.putValue(ByteBuffer buf, int off, int len) intStoreObjectAdapter.putValue(long addr) booleanStoreObjectAdapter.putValue(ByteBuffer buf) booleanStoreObjectAdapter.putValue(ByteBuffer buf, int off, int len) <T> TStoreObject.value(StoreContext ctx) <T> TStoreObjectImpl.value(StoreContext ctx) byte[]StoreObject.valueBytes(StoreContext ctx) byte[]StoreObjectImpl.valueBytes(StoreContext ctx) intStoreObject.valueBytesLength(StoreContext ctx) intStoreObjectAdapter.valueBytesLength(StoreContext ctx) -
Uses of IgniteCheckedException in org.apache.ignite.internal.persistence.tree
Subclasses of IgniteCheckedException in org.apache.ignite.internal.persistence.treeModifier and TypeClassDescriptionclassException to distinguishBPlusTreetree broken invariants.Methods in org.apache.ignite.internal.persistence.tree that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionprotected final longBPlusTree.acquirePage(long pageId) booleanPerforms inspection or operation on a specified row and returns true if this row is required or matches or /operation successful (depending on the context).protected final voidBPlusTree.checkDestroyed()Check if the tree is getting destroyed.protected intprotected abstract intprotected intBPlusTreeReplaceRemoveRaceTest.TestPairTree.compare(BPlusIO<BPlusTreeReplaceRemoveRaceTest.Pair> io, long pageAddr, int idx, BPlusTreeReplaceRemoveRaceTest.Pair n2) final longBPlusTree.destroy()Destroys tree.final longBPlusTree.destroy(IgniteInClosure<L> c, boolean forceDestroy) Destroys tree.protected longBPlusTree.destroyDownPages(LongListReuseBag bag, long pageId, int lvl, IgniteInClosure<L> c, AtomicLong lockHoldStartTime, long lockMaxTime, Deque<GridTuple3<Long, Long, Long>> lockedPages) Recursively destroys tree pages.protected voidBPlusTree.Remove.doRemove(long pageId, long page, long pageAddr, Boolean walPlc, BPlusIO<L> io, int cnt, int idx) protected BPlusTree.ResultBPlusTree.Remove.doRemoveFromLeaf()final GridCursor<T>Returns a cursor from lower to upper bounds inclusive.BPlusTree.find(L lower, L upper, boolean lowIncl, boolean upIncl, BPlusTree.TreeRowClosure<L, T> c, Object x) final GridCursor<T>Returns a cursor from lower to upper bounds inclusive.BPlusTree.findFirst()Returns a value mapped to the lowest key, ornullif tree is emptyBPlusTree.findFirst(BPlusTree.TreeRowClosure<L, T> filter) Returns a value mapped to the lowest key, ornullif tree is empty or no entry matches the passed filter.BPlusTree.findLast()Returns a value mapped to the greatest key, ornullif tree is emptyBPlusTree.findLast(BPlusTree.TreeRowClosure<L, T> c) Returns a value mapped to the greatest key, ornullif tree is empty or no entry matches the passed filter.final Tfinal <R> Rfinal <R> Rprotected BPlusTree.ResultBPlusTree.Put.finishOrLockTail(long pageId, long page, long backId, long fwdId, int lvl) Method that's invoked when operation goes up from the recursion andBPlusTree.Get.isFinished()returns false.protected BPlusTree.ResultBPlusTree.Remove.finishOrLockTail(long pageId, long page, long backId, long fwdId, int lvl) Method that's invoked when operation goes up from the recursion andBPlusTree.Get.isFinished()returns false.protected BPlusTree.ResultBPlusTree.Put.finishTail()Process tail and finish.protected BPlusTree.ResultBPlusTree.Remove.finishTail()Process tail and finish.voidKeyStoreObjectImpl.finishUnmarshal(StoreContext ctx, ClassLoader ldr) final TGet a full detached data row.abstract TGet data row.BPlusTreeReplaceRemoveRaceTest.TestPairTree.getRow(BPlusIO<BPlusTreeReplaceRemoveRaceTest.Pair> io, long pageAddr, int idx, Object ignore) Get data row.protected final voidBPlusTree.initTree(boolean initNew) Initialize new tree.protected final voidBPlusTree.initTree(boolean initNew, int inlineSize) Initialize new tree.voidBPlusTree.invoke(L row, Object z, IgniteTree.InvokeClosure<T> c) final booleanBPlusTree.isEmpty()voidprotected BPlusTree.ResultBPlusTree.Remove.lockForward(int lvl) voidKeyStoreObjectImpl.prepareMarshal(StoreContext ctx) final StringBPlusTree.printTree()For debug.final TPut value in this tree.booleanprotected booleanBPlusTree.Remove.releaseForRetry(org.apache.ignite.internal.persistence.tree.BPlusTree.Tail<L> t) protected booleanBPlusTree.RemoveRange.releaseForRetry(org.apache.ignite.internal.persistence.tree.BPlusTree.Tail<L> t) final Tprotected voidBPlusTree.Remove.removeDataRowFromLeaf(long pageId, long page, long pageAddr, Boolean walPlc, BPlusIO<L> io, int cnt, int idx) protected voidBPlusTree.RemoveRange.removeDataRowFromLeaf(long pageId, long page, long pageAddr, Boolean walPlc, BPlusIO<L> io, int cnt, int idx) final booleanvoidBPlusTree.Put.replaceRowInPage(BPlusIO<L> io, long pageId, long page, long pageAddr, int idx) Replaces a row in the page with a new one.final intBPlusTree.rootLevel()BPlusTree.Insert.run0(long pageId, long page, long pageAddr, BPlusIO<L> io, BPlusTree<L, T>.Put p, int lvl) BPlusTree.Replace.run0(long pageId, long page, long pageAddr, BPlusIO<L> io, BPlusTree<L, T>.Put p, int lvl) BPlusTree.Search.run0(long pageId, long page, long pageAddr, BPlusIO<L> io, BPlusTree<L, T>.Get g, int lvl) final longBPlusTree.size()Returns number of elements in the tree by scanning pages of the bottom (leaf) level.longBPlusTree.size(BPlusTree.TreeRowClosure<L, T> filter) Returns number of elements in the tree that match the filter by scanning through the pages of the leaf level.voidBPlusTreeReplaceRemoveRaceTest.tearDown()voidBPlusTreeTest.tearDown()voidBPlusTreeTest.testCursorConcurrentMerge()voidBPlusTreeTest.testEmptyCursors()voidBPlusTreeTest.testFind()voidBPlusTreeTest.testFindFirstAndLast()voidBPlusTreeTest.testFindWithClosure()voidBPlusTreeTest.testPutRemove_1_20_mm_0()voidBPlusTreeTest.testPutRemove_1_20_mm_1()voidBPlusTreeTest.testPutRemove_1_20_mp_0()voidBPlusTreeTest.testPutRemove_1_20_mp_1()voidBPlusTreeTest.testPutRemove_1_20_pm_0()voidBPlusTreeTest.testPutRemove_1_20_pm_1()voidBPlusTreeTest.testPutRemove_1_20_pp_0()voidBPlusTreeTest.testPutRemove_1_20_pp_1()voidBPlusTreeTest.testPutRemove_2_40_mm_0()voidBPlusTreeTest.testPutRemove_2_40_mm_1()voidBPlusTreeTest.testPutRemove_2_40_mp_0()voidBPlusTreeTest.testPutRemove_2_40_mp_1()voidBPlusTreeTest.testPutRemove_2_40_pm_0()voidBPlusTreeTest.testPutRemove_2_40_pm_1()voidBPlusTreeTest.testPutRemove_2_40_pp_0()voidBPlusTreeTest.testPutRemove_2_40_pp_1()voidBPlusTreeTest.testPutRemove_3_60_mm_0()voidBPlusTreeTest.testPutRemove_3_60_mm_1()voidBPlusTreeTest.testPutRemove_3_60_mp_0()voidBPlusTreeTest.testPutRemove_3_60_mp_1()voidBPlusTreeTest.testPutRemove_3_60_pm_0()voidBPlusTreeTest.testPutRemove_3_60_pm_1()voidBPlusTreeTest.testPutRemove_3_60_pp_0()voidBPlusTreeTest.testPutRemove_3_60_pp_1()voidBPlusTreeTest.testRandomInvoke_1_30_0()voidBPlusTreeTest.testRandomInvoke_1_30_1()voidBPlusTreeTest.testRandomPutRemove_1_30_0()voidBPlusTreeTest.testRandomPutRemove_1_30_1()voidBPlusTreeTest.testRetries()voidBPlusTreeTest.testSizeForPutRmvSequential()Verifies thatBPlusTree.size()andBPlusTree.size()methods behave correctly on single-threaded addition and removal of elements in random order.BPlusTree.Put.tryReplace(long pageId, long page, long fwdId, int lvl) final voidBPlusTree.validateTree()byte[]KeyStoreObjectImpl.valueBytes(StoreContext ctx) intBPlusTree.TreeVisitorClosure.visit(BPlusTree<L, T> tree, BPlusIO<L> io, long pageAddr, int idx, WalManager wal) Performs inspection or operation on a specified row.voidConstructors in org.apache.ignite.internal.persistence.tree that throw IgniteCheckedExceptionModifierConstructorDescriptionprotectedBPlusTree(String name, int cacheGrpId, int pageSize, PageMemory pageMem, WalManager wal, org.apache.ignite.internal.PageAccessHelper pageHandler, AtomicLong globalRmvId, long metaPageId, ReuseList reuseList, org.apache.ignite.internal.FailureProcessor failureProcessor, PageLockListener lsnr) protectedBPlusTree(String name, int cacheGrpId, int pageSize, PageMemory pageMem, WalManager wal, org.apache.ignite.internal.PageAccessHelper pageHandler, AtomicLong globalRmvId, long metaPageId, ReuseList reuseList, IOVersions<? extends BPlusInnerIO<L>> innerIos, IOVersions<? extends BPlusLeafIO<L>> leafIos, org.apache.ignite.internal.FailureProcessor failureProcessor, PageLockListener lockLsnr) TestPairTree(ReuseList reuseList, boolean canGetRow, int cacheId, PageMemory pageMem, WalManager walMgr, org.apache.ignite.internal.PageAccessHelper pageHandler, long metaPageId) -
Uses of IgniteCheckedException in org.apache.ignite.internal.persistence.tree.io
Methods in org.apache.ignite.internal.persistence.tree.io that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionintAbstractDataPageIO.addRow(long pageAddr, byte[] payload, int pageSize) Adds row to this data page and sets respective link to the given row object.voidAdds row to this data page and sets respective link to the given row object.voidAbstractDataPageIO.addRowFragment(long pageId, long pageAddr, byte[] payload, long lastLink, int pageSize) Adds this payload as a fragment to this data page.intAbstractDataPageIO.addRowFragment(PageMemory pageMem, long pageId, long pageAddr, T row, int written, int rowSize, int pageSize) Adds maximum possible fragment of the given row to this data page and sets respective link to the row.AbstractDataPageIO.CC.apply(long link) Closure body.final voidBPlusInnerIO.copyItems(long srcPageAddr, long dstPageAddr, int srcIdx, int dstIdx, int cnt, boolean cpLeft) Copy items from source page to destination page.abstract voidBPlusIO.copyItems(long srcPageAddr, long dstPageAddr, int srcIdx, int dstIdx, int cnt, boolean cpLeft) Copy items from source page to destination page.final voidBPlusLeafIO.copyItems(long srcPageAddr, long dstPageAddr, int srcIdx, int dstIdx, int cnt, boolean cpLeft) Copy items from source page to destination page.<T> List<T>AbstractDataPageIO.forAllItems(long pageAddr, AbstractDataPageIO.CC<T> c) static <Q extends BPlusIO<?>>
QPageIO.getBPlusIO(long pageAddr) abstract LBPlusIO.getLookupRow(BPlusTree<L, ?> tree, long pageAddr, int idx) Get lookup row.static <Q extends PageIO>
QPageIO.getPageIO(ByteBuffer page) byte[]BPlusInnerIO.initNewRoot(long newRootPageAddr, long newRootId, long leftChildId, L row, byte[] rowBytes, long rightChildId, int pageSize, boolean needRowBytes) byte[]BPlusInnerIO.insert(long pageAddr, int idx, L row, byte[] rowBytes, long rightId, boolean needRowBytes) byte[]booleanBPlusIO.merge(BPlusIO<L> prntIo, long prntPageAddr, int prntIdx, long leftPageAddr, long rightPageAddr, boolean emptyBranch, int pageSize) protected voidBPlusIO.printPage(long addr, int pageSize, GridStringBuilder sb) protected voidBPlusMetaIO.printPage(long addr, int pageSize, GridStringBuilder sb) protected abstract voidPageIO.printPage(long addr, int pageSize, GridStringBuilder sb) protected voidPageMetaIO.printPage(long addr, int pageSize, GridStringBuilder sb) protected voidSimpleDataPageIO.printPage(long addr, int pageSize, GridStringBuilder sb) voidBPlusIO.remove(long pageAddr, int idx, int cnt) longAbstractDataPageIO.removeRow(long pageAddr, int itemId, int pageSize) voidBPlusIO.splitForwardPage(long pageAddr, long fwdId, long fwdPageAddr, int mid, int cnt, int pageSize) final byte[]Store the needed info about the row in the page.abstract voidStore row info from the given source.abstract voidBPlusIO.storeByOffset(long pageAddr, int off, L row) Store the needed info about the row in the page.booleanAbstractDataPageIO.updateRow(long pageAddr, int itemId, int pageSize, byte[] payload, T row, int rowSize) protected abstract voidAbstractDataPageIO.writeFragmentData(T row, ByteBuffer buf, int rowOff, int payloadSize) Write row data fragment.protected voidSimpleDataPageIO.writeFragmentData(SimpleDataRow row, ByteBuffer buf, int rowOff, int payloadSize) Write row data fragment.protected abstract voidAbstractDataPageIO.writeRowData(long pageAddr, int dataOff, int payloadSize, T row, boolean newRow) protected voidSimpleDataPageIO.writeRowData(long pageAddr, int dataOff, int payloadSize, SimpleDataRow row, boolean newRow) -
Uses of IgniteCheckedException in org.apache.ignite.internal.persistence.tree.reuse
Methods in org.apache.ignite.internal.persistence.tree.reuse that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidReuseList.addForRecycle(ReuseBag bag) voidReuseListImpl.addForRecycle(ReuseBag bag) longReuseList.initRecycledPage(long pageId, byte flag, PageIO initIO) Converts recycled page id back to a usable id.longReuseListImpl.initRecycledPage(long pageId, byte flag, PageIO initIO) Converts recycled page id back to a usable id.longReuseList.recycledPagesCount()longReuseListImpl.recycledPagesCount()longReuseList.takeRecycledPage()longReuseListImpl.takeRecycledPage()Constructors in org.apache.ignite.internal.persistence.tree.reuse that throw IgniteCheckedExceptionModifierConstructorDescriptionReuseListImpl(int cacheId, String name, PageMemory pageMem, WalManager wal, org.apache.ignite.internal.PageAccessHelper pageHandler, long metaPageId, boolean initNew, int pageSize, PageLockListener lockLsnr, IgniteLogger logger, AtomicLong pageListCacheLimit) -
Uses of IgniteCheckedException in org.apache.ignite.internal.persistence.wal
Methods in org.apache.ignite.internal.persistence.wal that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidWal.close(boolean onError) Closes the log.voidOperationExecutor.executeOperation(Object descriptor) Executes an operation.voidWal.finishCheckpoint()Finishes a checkpoint.voidWalManager.finishCheckpoint()Finishes a checkpoint.voidWalManagerImpl.finishCheckpoint()voidWalManager.finishLogicalOperations(OperationExecutor logicalOperationExecutor, OperationSerializer logicalOperationSerializer) Finishes interrupted logical operations.voidWalManagerImpl.finishLogicalOperations(OperationExecutor logicalOperationExecutor, OperationSerializer logicalOperationSerializer) booleanChecks if the log has entries that were added after the last checkpoint had started.booleanChecks if the log has entries that had been added before the last checkpoint started.booleanWalManager.isLastCheckpointInterrupted()Checks if the last checkpoint was interrupted.booleanWalManagerImpl.isLastCheckpointInterrupted()voidWal.logDeferred(byte[] data, int offset, int length) Logs record deferredly.voidWalManager.logicalOperation(Object descriptor, OperationSerializer logicalOperationSerializer) Logs logical operation.voidWalManagerImpl.logicalOperation(Object descriptor, OperationSerializer logicalOperationSerializer) voidWal.logImmediately(byte[] data, int offset, int length) Logs record immediately.voidWalManager.physicalOperation(PhysicalOperationDescriptor descriptor) Logs physical operation.voidWalManagerImpl.physicalOperation(PhysicalOperationDescriptor descriptor) voidWal.EntryProcessor.process(byte[] data, int offset, int length) The method invoked byprocessRecordsBeforeLastCheckpointStartandprocessRecordsAfterLastCheckpointStartmethods.voidWal.processEntriesAfterLastCheckpointStart(Wal.EntryProcessor processor) Processes the entries that were added after the last checkpoint had started.voidWal.processEntriesBeforeLastCheckpointStart(Wal.EntryProcessor processor) Processes the entries that had been added before the last checkpoint started.longWal.size()Gets size.longWalManager.size()Gets size.longWalManagerImpl.size()voidWal.start()Starts the log.voidWalManager.start()Starts the log manager.voidWalManagerImpl.start()voidWal.startCheckpoint()Starts a checkpoint.voidWalManager.startCheckpoint()Starts a checkpoint.voidWalManagerImpl.startCheckpoint()voidWalImplTest.testLogConcurrentlyThenTerminate()voidWalImplTest.testLogDeferredConcurrentlyStartCpAndTerminate()voidWalImplTest.testLogDeferredStartCpFinishCpThenTerminate()voidvoidWalImplTest.testLogDeferredStartCpLogFinishCpThenTerminate()voidWalImplTest.testLogDeferredStartCpLogThenTerminate()voidWalImplTest.testLogDeferredStartCpThenTerminate()voidWalImplTest.testLogSequentiallyCheckChainIntegrity()voidWalImplTest.testLogStartCpFinishCpThenTerminate()voidWalImplTest.testLogStartCpLogFinishCpLogStartCpThenTerminate()voidWalImplTest.testLogStartCpLogFinishCpLogThenTerminate()voidWalImplTest.testLogStartCpLogFinishCpThenTerminate()voidWalImplTest.testLogStartCpLogTerminateLogTerminate()voidWalImplTest.testLogStartCpLogThenTerminate()voidWalImplTest.testLogStartCpThenTerminate()voidWalImplTest.testLogThenCloseNormally()voidWalImplTest.testLogThenTerminate()voidWalImplTest.testLogThenTerminateStartTerminate()voidWalImplTest.testSyncEntryAtTheEnd()voidWalImplTest.testSyncEntryInTheMiddle()voidWalImplTest.testTerminateEmptyLogThenStartAndLog() -
Uses of IgniteCheckedException in org.apache.ignite.internal.persistence.wal.record.delta
Modifier and TypeClassDescriptionclassThrown in case when delta application to the page failed.Methods in org.apache.ignite.internal.persistence.wal.record.delta that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidDataPageInsertFragmentRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidDataPageInsertRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidDataPageRemoveRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidDataPageSetFreeListPageRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidDataPageUpdateRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidFixCountRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidFixLeftmostChildRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidFixRemoveId.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidInitNewPageRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidInnerReplaceRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidInsertRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidMergeRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidMetaPageAddRootRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidMetaPageCutRootRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidMetaPageInitRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidMetaPageInitRootInlineFlagsCreatedVersionRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidMetaPageInitRootInlineRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidMetaPageInitRootRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidMetaPageUpdateRecord.applyDelta(int pageSize, long pageAddr) voidNewRootInitRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.abstract voidPageDeltaRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidPageListMetaResetCountRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidPagesListAddPageRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidPagesListInitNewPageRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidPagesListRemovePageRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidPagesListSetNextRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidPagesListSetPreviousRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidRecycleRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidRemoveRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidReplaceRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidRotatedIdPartRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidSplitExistingPageRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page.voidSplitForwardPageRecord.applyDelta(int pageSize, long pageAddr) Apply changes from this delta to the given page. -
Uses of IgniteCheckedException in org.apache.ignite.internal.util
Methods in org.apache.ignite.internal.util that return IgniteCheckedExceptionModifier and TypeMethodDescriptionstatic IgniteCheckedExceptionCasts the passedThrowable ttoIgniteCheckedException.
Iftis aGridClosureException, it is unwrapped and then cast toIgniteCheckedException.Methods in org.apache.ignite.internal.util that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionvoidReturns a cursor from lower to upper bounds inclusive.Returns a cursor from lower to upper bounds inclusive.IgniteTree.findFirst()Returns a value mapped to the lowest key, ornullif tree is emptyIgniteTree.findLast()Returns a value mapped to the greatest key, ornullif tree is emptyReturns the value to which the specified key is mapped, ornullif this tree contains no mapping for the key.GridCursorIteratorWrapper.get()Gets element at current position.voidIgniteTree.invoke(L key, Object x, IgniteTree.InvokeClosure<T> c) booleanGridCursorIteratorWrapper.next()Attempt to move cursor position forward.Put value in this tree.Removes the mapping for a key from this tree if it is present.longIgniteTree.size()Returns the number of elements in this tree. -
Uses of IgniteCheckedException in org.apache.ignite.internal.util.future
Methods in org.apache.ignite.internal.util.future that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionbooleanGridCompoundFuture.cancel()Default no-op implementation that always returnsfalse.booleanGridFutureAdapter.cancel()Default no-op implementation that always returnsfalse.GridFutureAdapter.get()Synchronously waits for completion of the computation and returns computation result.GridFutureAdapter.get(long timeout) Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.GridFutureAdapter.getUninterruptibly()Synchronously waits for completion of the computation and returns computation result ignoring interrupts. -
Uses of IgniteCheckedException in org.apache.ignite.internal.util.lang
Methods in org.apache.ignite.internal.util.lang that throw IgniteCheckedExceptionModifier and TypeMethodDescriptionabstract voidIn-closure body that can throwIgniteCheckedException.GridCursor.get()Gets element at current position.booleanGridIterator.hasNextX()This method is the same asIterator.hasNext(), but allows for failure with exception.booleanGridCursor.next()Attempt to move cursor position forward.GridIterator.nextX()This method is the same asIterator.next(), but allows for failure with exception.voidGridIterator.removeX()This method is the same asIterator.remove(), but allows for failure with exception. -
Uses of IgniteCheckedException in org.apache.ignite.marshaller
Methods in org.apache.ignite.marshaller that throw IgniteCheckedException