Uses of Interface
org.apache.ignite.internal.util.lang.IgniteThrowableFunction

Packages that use IgniteThrowableFunction

Package	Description
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.util	System-wide utility routine and helper classes.
org.apache.ignite.maintenance	Contains public interfaces for maintenance mechanism.

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

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

Modifier and Type	Method and Description
void	CacheDataRowAdapter.initFromPageBuffer(GridCacheSharedContext<?,?> sctx, CacheObjectContext coctx, IgniteThrowableFunction<Long,ByteBuffer> reader, ByteBuffer pageBuff, int itemId, boolean readCacheId, CacheDataRowAdapter.RowData rowData, boolean skipVer)

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

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

Constructor and Description
CheckpointManager(Function<Class<?>,IgniteLogger> logger, String igniteInstanceName, String checkpointThreadName, IgniteWriteAheadLogManager wal, WorkersRegistry workersRegistry, DataStorageConfiguration persistenceCfg, FilePageStoreManager pageStoreManager, IgniteThrowableBiPredicate<Long,Integer> checkpointInapplicableChecker, Supplier<Collection<DataRegion>> dataRegions, Supplier<Collection<CacheGroupContext>> cacheGroupContexts, IgniteThrowableFunction<Integer,PageMemoryEx> pageMemoryGroupResolver, PageMemoryImpl.ThrottlingPolicy throttlingPolicy, IgniteCacheSnapshotManager snapshotMgr, DataStorageMetricsImpl persStoreMetrics, LongJVMPauseDetector longJvmPauseDetector, FailureProcessor failureProcessor, GridCacheProcessor cacheProcessor, Supplier<Integer> cpFreqDeviation)
LightweightCheckpointManager(Function<Class<?>,IgniteLogger> logger, String igniteInstanceName, String checkpointThreadName, WorkersRegistry workersRegistry, DataStorageConfiguration persistenceCfg, Supplier<Collection<DataRegion>> dataRegions, IgniteThrowableFunction<Integer,PageMemoryEx> pageMemoryGroupResolver, PageMemoryImpl.ThrottlingPolicy throttlingPolicy, IgniteCacheSnapshotManager snapshotMgr, DataStorageMetricsImpl persStoreMetrics, LongJVMPauseDetector longJvmPauseDetector, FailureProcessor failureProcessor, GridCacheProcessor cacheProcessor)

Uses of IgniteThrowableFunction in org.apache.ignite.internal.util

Methods in org.apache.ignite.internal.util with parameters of type IgniteThrowableFunction

Modifier and Type	Method and Description
static <T,R> Collection<R>	IgniteUtils.doInParallel(ExecutorService executorSvc, Collection<T> srcDatas, IgniteThrowableFunction<T,R> operation) Execute operation on data in parallel.
static <T,R> Collection<R>	IgniteUtils.doInParallel(int parallelismLvl, ExecutorService executorSvc, Collection<T> srcDatas, IgniteThrowableFunction<T,R> operation) Execute operation on data in parallel.
static <T,R> Collection<R>	IgniteUtils.doInParallelUninterruptibly(int parallelismLvl, ExecutorService executorSvc, Collection<T> srcDatas, IgniteThrowableFunction<T,R> operation) Execute operation on data in parallel uninterruptibly.

Uses of IgniteThrowableFunction in org.apache.ignite.maintenance

Methods in org.apache.ignite.maintenance with parameters of type IgniteThrowableFunction

Modifier and Type	Method and Description
default void	MaintenanceRegistry.registerWorkflowCallbackIfTaskExists(@NotNull String maintenanceTaskName, @NotNull IgniteThrowableFunction<MaintenanceTask,MaintenanceWorkflowCallback> workflowCalProvider) Call the MaintenanceRegistry.registerWorkflowCallback(String, MaintenanceWorkflowCallback) if the active maintenance task with given name exists.