Uses of Interface
org.apache.ignite.lang.IgniteInClosure
-
-
Uses of IgniteInClosure in org.apache.ignite.configuration
Methods in org.apache.ignite.configuration that return IgniteInClosure Modifier and Type Method Description IgniteInClosure<IgniteConfiguration>IgniteConfiguration. getWarmupClosure()Gets grid warmup closure.Methods in org.apache.ignite.configuration with parameters of type IgniteInClosure Modifier and Type Method Description IgniteConfigurationIgniteConfiguration. setWarmupClosure(IgniteInClosure<IgniteConfiguration> warmupClos)Sets warmup closure to execute before grid startup. -
Uses of IgniteInClosure in org.apache.ignite.internal
Methods in org.apache.ignite.internal with parameters of type IgniteInClosure Modifier and Type Method Description voidIgniteInternalFuture. listen(IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)Registers listener closure to be asynchronously notified whenever future completes.voidIgniteDiagnosticPrepareContext. send(GridKernalContext ctx, @Nullable IgniteInClosure<IgniteInternalFuture<String>> lsnr) -
Uses of IgniteInClosure in org.apache.ignite.internal.managers.communication
Methods in org.apache.ignite.internal.managers.communication with parameters of type IgniteInClosure Modifier and Type Method Description voidGridIoManager. sendOrderedMessage(ClusterNode node, Object topic, Message msg, byte plc, long timeout, boolean skipOnTimeout, IgniteInClosure<IgniteException> ackC)voidGridIoManager. sendToGridTopic(ClusterNode node, GridTopic topic, Message msg, byte plc, IgniteInClosure<IgniteException> ackC) -
Uses of IgniteInClosure in org.apache.ignite.internal.managers.discovery
Methods in org.apache.ignite.internal.managers.discovery with parameters of type IgniteInClosure Modifier and Type Method Description voidGridDiscoveryManager. addLocalNodeInitializedEventListener(IgniteInClosure<ClusterNode> lsnr)Adds a listener for local node initialized event. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.bulkload
Classes in org.apache.ignite.internal.processors.bulkload that implement IgniteInClosure Modifier and Type Class Description classBulkLoadCacheWriterA proxy, which stores given key+value pair to a cache.classBulkLoadStreamerWriterA bulk load cache writer object that adds entries usingIgniteDataStreamer. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.cache
Subinterfaces of IgniteInClosure in org.apache.ignite.internal.processors.cache Modifier and Type Interface Description static interfaceGridCacheUtils.BackupPostProcessingClosureMethods in org.apache.ignite.internal.processors.cache that return IgniteInClosure Modifier and Type Method Description static IgniteInClosure<IgniteInternalFuture<?>>GridCacheUtils. errorLogger(IgniteLogger log, Class<? extends Exception>... excl) -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.cache.distributed
Classes in org.apache.ignite.internal.processors.cache.distributed that implement IgniteInClosure Modifier and Type Class Description classGridCacheTxRecoveryFutureFuture verifying that all remote transactions related to transaction were prepared or committed. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.cache.distributed.dht
Classes in org.apache.ignite.internal.processors.cache.distributed.dht that implement IgniteInClosure Modifier and Type Class Description classCacheDistributedGetFutureAdapter<K,V>classGridDhtGetFuture<K,V>classGridDhtLockFutureCache lock future.classGridDhtTxFinishFuture<K,V>classGridDhtTxPrepareFutureclassGridPartitionedGetFuture<K,V>Colocated get future. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.cache.distributed.dht.colocated
Classes in org.apache.ignite.internal.processors.cache.distributed.dht.colocated that implement IgniteInClosure Modifier and Type Class Description classGridDhtColocatedLockFutureColocated cache lock future. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.cache.distributed.dht.preloader
Classes in org.apache.ignite.internal.processors.cache.distributed.dht.preloader that implement IgniteInClosure Modifier and Type Class Description classGridDhtForceKeysFuture<K,V>Force keys request future.classInitNewCoordinatorFuture -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.cache.distributed.near
Classes in org.apache.ignite.internal.processors.cache.distributed.near that implement IgniteInClosure Modifier and Type Class Description classGridNearGetFuture<K,V>classGridNearLockFutureCache lock future.classGridNearOptimisticSerializableTxPrepareFutureclassGridNearOptimisticTxPrepareFutureclassGridNearOptimisticTxPrepareFutureAdapterclassGridNearPessimisticTxPrepareFutureclassGridNearTxFinishFuture<K,V>classGridNearTxPrepareFutureAdapterCommon code for tx prepare in optimistic and pessimistic modes. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.cache.distributed.near.consistency
Classes in org.apache.ignite.internal.processors.cache.distributed.near.consistency that implement IgniteInClosure Modifier and Type Class Description classGridCompoundReadRepairFutureCompound future that represents the result of the external fixes for some keys. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.cache.persistence
Methods in org.apache.ignite.internal.processors.cache.persistence with parameters of type IgniteInClosure Modifier and Type Method Description <R> CheckpointProgressGridCacheDatabaseSharedManager. forceNewCheckpoint(String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)Schedule a new checkpoint.<R> @Nullable CheckpointProgressIgniteCacheDatabaseSharedManager. forceNewCheckpoint(String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)Schedule a new checkpoint.<R> voidGridCacheDatabaseSharedManager. waitForCheckpoint(String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)Waits until current state is checkpointed and execution listeners after finish.<R> voidIgniteCacheDatabaseSharedManager. waitForCheckpoint(String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)Waits until current state is checkpointed and execution listeners after finish. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.cache.persistence.checkpoint
Methods in org.apache.ignite.internal.processors.cache.persistence.checkpoint with parameters of type IgniteInClosure Modifier and Type Method Description <R> CheckpointProgressCheckpointManager. forceCheckpoint(String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)Start the new checkpoint immediately.<R> CheckpointProgressLightweightCheckpointManager. forceCheckpoint(String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)Start the new checkpoint immediately.<R> CheckpointProgressCheckpointer. scheduleCheckpoint(long delayFromNow, String reason, IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)Change the information for a scheduled checkpoint if it was scheduled further thandelayFromNow, or do nothing otherwise. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.cache.persistence.tree
Methods in org.apache.ignite.internal.processors.cache.persistence.tree with parameters of type IgniteInClosure Modifier and Type Method Description longBPlusTree. destroy(@Nullable IgniteInClosure<L> c, boolean forceDestroy)Destroys tree.protected longBPlusTree. destroyDownPages(LongListReuseBag bag, long pageId, int lvl, @Nullable IgniteInClosure<L> c, AtomicLong lockHoldStartTime, long lockMaxTime, Deque<GridTuple3<Long,Long,Long>> lockedPages)Recursively destroys tree pages. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.cache.persistence.tree.io
Methods in org.apache.ignite.internal.processors.cache.persistence.tree.io with parameters of type IgniteInClosure Modifier and Type Method Description voidBPlusIO. visit(long pageAddr, IgniteInClosure<L> c) -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.cache.persistence.wal
Methods in org.apache.ignite.internal.processors.cache.persistence.wal with parameters of type IgniteInClosure Modifier and Type Method Description voidFileWriteAheadLogManager. setCreateWalFileListener(@Nullable IgniteInClosure<FileIO> createWalFileListener)Setup listener for WAL segment write File IO creation. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.cache.tree
Methods in org.apache.ignite.internal.processors.cache.tree with parameters of type IgniteInClosure Modifier and Type Method Description voidAbstractDataInnerIO. visit(long pageAddr, IgniteInClosure<CacheSearchRow> c)voidAbstractDataLeafIO. visit(long pageAddr, IgniteInClosure<CacheSearchRow> c) -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.cache.verify
Classes in org.apache.ignite.internal.processors.cache.verify that implement IgniteInClosure Modifier and Type Class Description static classIdleVerifyUtility.IdleCheckerIdle checker. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.platform.compute
Methods in org.apache.ignite.internal.processors.platform.compute with parameters of type IgniteInClosure Modifier and Type Method Description voidPlatformCompute.ComputeConvertingFuture. listen(IgniteInClosure lsnr)Registers listener closure to be asynchronously notified whenever future completes. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.platform.dotnet
Methods in org.apache.ignite.internal.processors.platform.dotnet with parameters of type IgniteInClosure Modifier and Type Method Description protected intPlatformDotNetCacheStore. doInvoke(IgniteInClosure<BinaryRawWriterEx> task, IgniteInClosure<BinaryRawReaderEx> readClo)Perform actual invoke. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.query.schema
Classes in org.apache.ignite.internal.processors.query.schema that implement IgniteInClosure Modifier and Type Class Description classSchemaIndexCacheCompoundFutureCompound index rebuilding feature. -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.security.thread
Constructors in org.apache.ignite.internal.processors.security.thread with parameters of type IgniteInClosure Constructor Description SecurityAwareStripedExecutor(IgniteSecurity security, int cnt, String igniteInstanceName, String poolName, IgniteLogger log, IgniteInClosure<Throwable> errHnd, boolean stealTasks, GridWorkerListener gridWorkerLsnr, long failureDetectionTimeout)SecurityAwareStripedExecutor(IgniteSecurity security, int cnt, String igniteInstanceName, String poolName, IgniteLogger log, IgniteInClosure<Throwable> errHnd, GridWorkerListener gridWorkerLsnr, long failureDetectionTimeout) -
Uses of IgniteInClosure in org.apache.ignite.internal.processors.service
Classes in org.apache.ignite.internal.processors.service that implement IgniteInClosure Modifier and Type Class Description classGridServiceDeploymentCompoundFuture<T extends Serializable>Service deployment compound future. -
Uses of IgniteInClosure in org.apache.ignite.internal.util
Methods in org.apache.ignite.internal.util with parameters of type IgniteInClosure Modifier and Type Method Description static GridJavaProcessGridJavaProcess. exec(Class cls, String params, @Nullable IgniteLogger log, @Nullable IgniteInClosure<String> printC, @Nullable GridAbsClosure procKilledC)Executes main() method of the given class in a separate system process.static GridJavaProcessGridJavaProcess. exec(Class cls, String params, @Nullable IgniteLogger log, @Nullable IgniteInClosure<String> printC, @Nullable GridAbsClosure procKilledC, @Nullable Collection<String> jvmArgs, @Nullable String cp)Executes main() method of the given class in a separate system process.static GridJavaProcessGridJavaProcess. exec(String clsName, String params, @Nullable IgniteLogger log, @Nullable IgniteInClosure<String> printC, @Nullable GridAbsClosure procKilledC, @Nullable String javaHome, @Nullable Collection<String> jvmArgs, @Nullable String cp)Executes main() method of the given class in a separate system process.voidGridCircularBuffer. forEach(IgniteInClosure<T> c)Executes given closure for every item in circular buffer.Constructors in org.apache.ignite.internal.util with parameters of type IgniteInClosure Constructor Description Stripe(String igniteInstanceName, String poolName, int idx, IgniteLogger log, IgniteInClosure<Throwable> errHnd, GridWorkerListener gridWorkerLsnr, HistogramMetricImpl execTime)StripedExecutor(int cnt, String igniteInstanceName, String poolName, IgniteLogger log, IgniteInClosure<Throwable> errHnd, boolean stealTasks, GridWorkerListener gridWorkerLsnr, long failureDetectionTimeout)StripedExecutor(int cnt, String igniteInstanceName, String poolName, IgniteLogger log, IgniteInClosure<Throwable> errHnd, GridWorkerListener gridWorkerLsnr, long failureDetectionTimeout) -
Uses of IgniteInClosure in org.apache.ignite.internal.util.future
Classes in org.apache.ignite.internal.util.future that implement IgniteInClosure Modifier and Type Class Description classAsyncFutureListener<V>Wraps listener and executes it in specified executor.classGridCompoundFuture<T,R>Future composed of multiple inner futures.classGridCompoundIdentityFuture<T>Compound future with reducer which accepts and produces results of the same type.Methods in org.apache.ignite.internal.util.future with parameters of type IgniteInClosure Modifier and Type Method Description voidGridFinishedFuture. listen(IgniteInClosure<? super IgniteInternalFuture<T>> lsnr)Registers listener closure to be asynchronously notified whenever future completes.voidGridFutureAdapter. listen(IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)Registers listener closure to be asynchronously notified whenever future completes.voidIgniteFutureImpl. listen(IgniteInClosure<? super IgniteFuture<V>> lsnr)Registers a callback to be invoked when the future completes.voidIgniteFutureImpl. listenAsync(IgniteInClosure<? super IgniteFuture<V>> lsnr, Executor exec)Registers a callback to be invoked with the specified executor when the future completes.Constructors in org.apache.ignite.internal.util.future with parameters of type IgniteInClosure Constructor Description AsyncFutureListener(IgniteInClosure<? super IgniteFuture<V>> lsnr, Executor exec) -
Uses of IgniteInClosure in org.apache.ignite.internal.util.lang
Classes in org.apache.ignite.internal.util.lang that implement IgniteInClosure Modifier and Type Class Description classIgniteInClosureX<T>Convenient in-closure subclass that allows for thrown grid exception.Methods in org.apache.ignite.internal.util.lang with parameters of type IgniteInClosure Modifier and Type Method Description static <X> voidGridFunc. forEach(Iterable<? extends X> c, IgniteInClosure<? super X> f, @Nullable IgnitePredicate<? super X>... p)Deprecated.static <X> voidGridFunc. forEach(X[] c, IgniteInClosure<? super X> f, @Nullable IgnitePredicate<? super X>... p)Deprecated. -
Uses of IgniteInClosure in org.apache.ignite.internal.util.nio
Fields in org.apache.ignite.internal.util.nio declared as IgniteInClosure Modifier and Type Field Description protected IgniteInClosure<IgniteException>GridNioFutureImpl. ackCMethods in org.apache.ignite.internal.util.nio that return IgniteInClosure Modifier and Type Method Description IgniteInClosure<IgniteException>GridNioFinishedFuture. ackClosure()IgniteInClosure<IgniteException>GridNioFuture. ackClosure()IgniteInClosure<IgniteException>GridNioFutureImpl. ackClosure()IgniteInClosure<IgniteException>SessionWriteRequest. ackClosure()Methods in org.apache.ignite.internal.util.nio with parameters of type IgniteInClosure Modifier and Type Method Description GridNioFuture<GridNioSession>GridNioServer. createSession(SocketChannel ch, @Nullable Map<Integer,Object> meta, boolean async, @Nullable IgniteInClosure<? super IgniteInternalFuture<GridNioSession>> lsnr)Establishes a session.GridNioFuture<?>GridConnectionBytesVerifyFilter. onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Invoked when a write request is performed on a session.GridNioFuture<?>GridNioAsyncNotifyFilter. onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Invoked when a write request is performed on a session.GridNioFuture<?>GridNioCodecFilter. onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Invoked when a write request is performed on a session.GridNioFuture<?>GridNioFilter. onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Invoked when a write request is performed on a session.GridNioFuture<?>GridNioFilterChain. onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Starts chain notification from tail to head.GridNioFuture<?>GridNioTracerFilter. onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Invoked when a write request is performed on a session.GridNioFuture<?>GridNioFilter. proceedSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Forwards write request to the next logical filter in filter chain.GridNioFuture<?>GridNioFilterAdapter. proceedSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Forwards write request to the next logical filter in filter chain.booleanGridCommunicationClient. sendMessage(@Nullable UUID nodeId, Message msg, @Nullable IgniteInClosure<IgniteException> c)booleanGridTcpNioCommunicationClient. sendMessage(@Nullable UUID nodeId, Message msg, IgniteInClosure<IgniteException> c)voidGridNioSession. sendNoFuture(Object msg, @Nullable IgniteInClosure<IgniteException> ackC)voidGridNioSessionImpl. sendNoFuture(Object msg, IgniteInClosure<IgniteException> ackC)voidGridNioServer. sendSystem(GridNioSession ses, Message msg, @Nullable IgniteInClosure<? super IgniteInternalFuture<?>> lsnr)Adds message at the front of the queue without acquiring back pressure semaphore.booleanGridNioRecoveryDescriptor. tryReserve(long id, IgniteInClosure<Boolean> c)Constructors in org.apache.ignite.internal.util.nio with parameters of type IgniteInClosure Constructor Description GridNioFutureImpl(IgniteInClosure<IgniteException> ackC) -
Uses of IgniteInClosure in org.apache.ignite.internal.util.nio.ssl
Methods in org.apache.ignite.internal.util.nio.ssl with parameters of type IgniteInClosure Modifier and Type Method Description GridNioFuture<?>GridNioSslFilter. onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Invoked when a write request is performed on a session. -
Uses of IgniteInClosure in org.apache.ignite.internal.util.typedef
Subinterfaces of IgniteInClosure in org.apache.ignite.internal.util.typedef Modifier and Type Interface Description interfaceCI1<T>DefinesaliasforIgniteInClosureby extending it.Classes in org.apache.ignite.internal.util.typedef that implement IgniteInClosure Modifier and Type Class Description classCIX1<T>DefinesaliasforIgniteInClosureXby extending it. -
Uses of IgniteInClosure in org.apache.ignite.lang
Methods in org.apache.ignite.lang with parameters of type IgniteInClosure Modifier and Type Method Description voidIgniteFuture. listen(IgniteInClosure<? super IgniteFuture<V>> lsnr)Registers a callback to be invoked when the future completes.voidIgniteFuture. listenAsync(IgniteInClosure<? super IgniteFuture<V>> lsnr, Executor exec)Registers a callback to be invoked with the specified executor when the future completes. -
Uses of IgniteInClosure in org.apache.ignite.spi.communication.tcp
Methods in org.apache.ignite.spi.communication.tcp with parameters of type IgniteInClosure Modifier and Type Method Description voidTcpCommunicationSpi. sendMessage(ClusterNode node, Message msg, IgniteInClosure<IgniteException> ackC)Sends given message to destination node. -
Uses of IgniteInClosure in org.apache.ignite.spi.discovery.tcp
Fields in org.apache.ignite.spi.discovery.tcp with type parameters of type IgniteInClosure Modifier and Type Field Description protected CopyOnWriteArrayList<IgniteInClosure<Socket>>TcpDiscoverySpi. incomeConnLsnrsprotected CopyOnWriteArrayList<IgniteInClosure<TcpDiscoveryAbstractMessage>>TcpDiscoverySpi. sndMsgLsnrsMethods in org.apache.ignite.spi.discovery.tcp with parameters of type IgniteInClosure Modifier and Type Method Description voidTcpDiscoverySpi. addIncomeConnectionListener(IgniteInClosure<Socket> lsnr)FOR TEST ONLY!!!voidTcpDiscoverySpi. addSendMessageListener(IgniteInClosure<TcpDiscoveryAbstractMessage> lsnr)FOR TEST ONLY!!!voidTcpDiscoverySpi. removeIncomeConnectionListener(IgniteInClosure<Socket> lsnr)FOR TEST ONLY!!!voidTcpDiscoverySpi. removeSendMessageListener(IgniteInClosure<TcpDiscoveryAbstractMessage> lsnr)FOR TEST ONLY!!! -
Uses of IgniteInClosure in org.apache.ignite.startup
Classes in org.apache.ignite.startup that implement IgniteInClosure Modifier and Type Class Description classBasicWarmupClosureBasic warm-up closure which warm-ups cache operations.
-