org.apache.ignite.internal.processors.cache

Interface GridCachePreloader

All Known Implementing Classes:

GridCachePreloaderAdapter, GridDhtPreloader

public interface GridCachePreloader

Cache preloader that is responsible for loading cache entries either from remote nodes (for distributed cache) or anywhere else at cache startup.

Method Summary

Methods

Modifier and Type	Method and Description
Callable<Boolean>	addAssignments(GridDhtPreloaderAssignments assignments, boolean forcePreload, Collection<String> caches, int cnt) Adds assignments to preloader.
GridDhtPreloaderAssignments	assign(GridDhtPartitionsExchangeFuture exchFut)
void	dumpDebugInfo() Dumps debug information.
void	evictPartitionAsync(GridDhtLocalPartition part) Evicts partition asynchronously.
void	forcePreload() Force preload process.
void	handleDemandMessage(int idx, UUID id, GridDhtPartitionDemandMessage d) Handles Demand message.
void	handleSupplyMessage(int idx, UUID id, GridDhtPartitionSupplyMessageV2 s) Handles Supply message.
IgniteInternalFuture<?>	initialRebalanceFuture()
void	onExchangeFutureAdded() Callback by exchange manager when new exchange future is added to worker.
void	onInitialExchangeComplete(Throwable err) Callback by exchange manager when initial partition exchange is complete.
void	onKernalStart() Kernal start callback.
void	onKernalStop() Kernal stop callback.
void	onReconnected() Client reconnected callback.
void	onTopologyChanged(AffinityTopologyVersion topVer) Handles new topology.
IgnitePredicate<GridCacheEntryInfo>	preloadPredicate()
void	preloadPredicate(IgnitePredicate<GridCacheEntryInfo> p)
IgniteInternalFuture<Boolean>	rebalanceFuture()
IgniteInternalFuture<Object>	request(Collection<KeyCacheObject> keys, AffinityTopologyVersion topVer) Requests that preloader sends the request for the key.
void	start() Starts preloading.
IgniteInternalFuture<Object>	startFuture()
void	stop() Stops preloading.
IgniteInternalFuture<?>	syncFuture()
void	unwindUndeploys() Unwinds undeploys.
void	updateLastExchangeFuture(GridDhtPartitionsExchangeFuture lastFut) Updates last exchange future.

Method Detail

start

void start()
           throws IgniteCheckedException

Starts preloading.

Throws:

IgniteCheckedException - If start failed.

stop

void stop()

Stops preloading.

onKernalStart

void onKernalStart()
                   throws IgniteCheckedException

Kernal start callback.

Throws:

IgniteCheckedException - If failed.

onKernalStop

void onKernalStop()

Kernal stop callback.

onReconnected

void onReconnected()

Client reconnected callback.

onInitialExchangeComplete

void onInitialExchangeComplete(@Nullable
                             Throwable err)

Callback by exchange manager when initial partition exchange is complete.

Parameters:

err - Error, if any happened on initial exchange.

onExchangeFutureAdded

void onExchangeFutureAdded()

Callback by exchange manager when new exchange future is added to worker.

updateLastExchangeFuture

void updateLastExchangeFuture(GridDhtPartitionsExchangeFuture lastFut)

Updates last exchange future.

Parameters:

lastFut - Last future.

assign

GridDhtPreloaderAssignments assign(GridDhtPartitionsExchangeFuture exchFut)

Parameters:

exchFut - Exchange future to assign.

Returns:

Assignments.

addAssignments

Callable<Boolean> addAssignments(GridDhtPreloaderAssignments assignments,
                               boolean forcePreload,
                               Collection<String> caches,
                               int cnt)

Adds assignments to preloader.

Parameters:

assignments - Assignments to add.

forcePreload - Force preload flag.

caches - Rebalancing of these caches will be finished before this started.

cnt - Counter.

preloadPredicate

void preloadPredicate(IgnitePredicate<GridCacheEntryInfo> p)

Parameters:

p - Preload predicate.

preloadPredicate

IgnitePredicate<GridCacheEntryInfo> preloadPredicate()

Returns:

Preload predicate. If not null, will evaluate each preloaded entry during send and receive, and if predicate evaluates to false, entry will be skipped.

startFuture

IgniteInternalFuture<Object> startFuture()

Returns:

Future which will complete when preloader is safe to use.

syncFuture

IgniteInternalFuture<?> syncFuture()

Returns:

Future which will complete when preloading is finished.

rebalanceFuture

IgniteInternalFuture<Boolean> rebalanceFuture()

Returns:

Future which will complete when preloading finishes on current topology. Future result is true in case rebalancing successfully finished at current topology. Future result is false in case rebalancing cancelled or finished with missed partitions and will be restarted at current or pending topology. Note that topology change creates new futures and finishes previous.

request

IgniteInternalFuture<Object> request(Collection<KeyCacheObject> keys,
                                   AffinityTopologyVersion topVer)

Requests that preloader sends the request for the key.

Parameters:

keys - Keys to request.

topVer - Topology version, -1 if not required.

Returns:

Future to complete when all keys are preloaded.

initialRebalanceFuture

IgniteInternalFuture<?> initialRebalanceFuture()

Returns:

Future completed when rebalance on node start topology finished.

forcePreload

void forcePreload()

Force preload process.

unwindUndeploys

void unwindUndeploys()

Unwinds undeploys.

handleSupplyMessage

void handleSupplyMessage(int idx,
                       UUID id,
                       GridDhtPartitionSupplyMessageV2 s)

Handles Supply message.

Parameters:

idx - Index.

id - Node Id.

s - Supply message.

handleDemandMessage

void handleDemandMessage(int idx,
                       UUID id,
                       GridDhtPartitionDemandMessage d)

Handles Demand message.

Parameters:

idx - Index.

id - Node Id.

d - Demand message.

evictPartitionAsync

void evictPartitionAsync(GridDhtLocalPartition part)

Evicts partition asynchronously.

Parameters:

part - Partition.

onTopologyChanged

void onTopologyChanged(AffinityTopologyVersion topVer)

Handles new topology.

Parameters:

topVer - Topology version.

dumpDebugInfo

void dumpDebugInfo()

Dumps debug information.