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	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	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, DataStorageMetricsImpl persStoreMetrics, LongJVMPauseDetector longJvmPauseDetector, FailureProcessor failureProcessor, GridCacheProcessor cacheProcessor, Supplier<Integer> cpFreqDeviation, Executor checkpointMapSnapshotExecutor, JdkMarshaller marsh)
LightweightCheckpointManager(Function<Class<?>,IgniteLogger> logger, String igniteInstanceName, String checkpointThreadName, WorkersRegistry workersRegistry, DataStorageConfiguration persistenceCfg, Supplier<Collection<DataRegion>> dataRegions, IgniteThrowableFunction<Integer,PageMemoryEx> pageMemoryGroupResolver, PageMemoryImpl.ThrottlingPolicy throttlingPolicy, 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	Description
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.doInParallel(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	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.