com.hazelcast.spi.impl.merge

Class AbstractSplitBrainHandlerService<Store>

java.lang.Object

com.hazelcast.spi.impl.merge.AbstractSplitBrainHandlerService<Store>

Type Parameters:

Store - store of a partition

All Implemented Interfaces:

SplitBrainHandlerService

public abstract class AbstractSplitBrainHandlerService<Store>
extends Object
implements SplitBrainHandlerService

Collects mergeable stores and passes them to merge-runnable.

Since:

3.10

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractSplitBrainHandlerService(NodeEngine nodeEngine)

Method Summary

Modifier and Type	Method and Description
protected abstract void	destroyStore(Store store) Destroys the given Store.
protected abstract boolean	hasEntries(Store store) Checks if the given Store has entries.
protected abstract boolean	hasMergeablePolicy(Store store) Checks if the given Store has a mergeable merge policy.
protected abstract Runnable	newMergeRunnable(Collection<Store> mergingStores) Returns a runnable which merges the given Store instances.
protected void	onStoreCollection(Store store) Final cleanup before starting merge after StoreCollector collects a store.
Runnable	prepareMergeRunnable() When the two separate clusters merge (resolve a split-brain), this method is called to return a Runnable, that will merge the clusters.
protected abstract Iterator<Store>	storeIterator(int partitionId) Returns an Iterator over all Store instances in the given partition.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractSplitBrainHandlerService

protected AbstractSplitBrainHandlerService(NodeEngine nodeEngine)

Method Detail

prepareMergeRunnable

public final Runnable prepareMergeRunnable()

Description copied from interface: SplitBrainHandlerService

When the two separate clusters merge (resolve a split-brain), this method is called to return a Runnable, that will merge the clusters.

Specified by:

prepareMergeRunnable in interface SplitBrainHandlerService

Returns:

a Runnable that will merge the clusters

onStoreCollection

protected void onStoreCollection(Store store)

Final cleanup before starting merge after StoreCollector collects a store. If we do this cleanup upon join of merging node, concurrently running merge and migration operations can cause inconsistency over shared data. For example, dropping of map indexes is done at this stage not to lose index data.

newMergeRunnable

protected abstract Runnable newMergeRunnable(Collection<Store> mergingStores)

Returns a runnable which merges the given Store instances.

Returns:

a merge runnable for the given stores

storeIterator

protected abstract Iterator<Store> storeIterator(int partitionId)

Returns an Iterator over all Store instances in the given partition.

Returns:

an iterator over all stores

destroyStore

protected abstract void destroyStore(Store store)

Destroys the given Store.

hasEntries

protected abstract boolean hasEntries(Store store)

Checks if the given Store has entries.

Returns:

true if the store has entries, false otherwise

hasMergeablePolicy

protected abstract boolean hasMergeablePolicy(Store store)

Checks if the given Store has a mergeable merge policy.

Returns:

true if the store has a mergeable merge policy, false otherwise