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

Contains common functionality to implement a SplitBrainHandlerService.

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 provided store.
void	destroyStores(Collection<Store> recordStores)
protected abstract String	getDataStructureName(Store store)
protected abstract Object	getMergePolicy(String dataStructureName)
protected boolean	isDiscardPolicy(Object mergePolicy)
protected abstract Collection<Iterator<Store>>	iteratorsOf(int partitionId)
protected abstract Runnable	newMergeRunnable(Map<String,Collection<Store>> collectedStores, Map<String,Collection<Store>> collectedStoresWithLegacyPolicies, Collection<Store> backupStores, NodeEngine nodeEngine)
protected void	onPrepareMergeRunnableEnd(Collection<String> dataStructureNames)
protected void	onPrepareMergeRunnableStart()
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.

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

onPrepareMergeRunnableStart

protected void onPrepareMergeRunnableStart()

onPrepareMergeRunnableEnd

protected void onPrepareMergeRunnableEnd(Collection<String> dataStructureNames)

isDiscardPolicy

protected boolean isDiscardPolicy(Object mergePolicy)

destroyStores

public void destroyStores(Collection<Store> recordStores)

destroyStore

protected abstract void destroyStore(Store store)

Destroys the provided store.

getDataStructureName

protected abstract String getDataStructureName(Store store)

Returns:

name of the data structure

getMergePolicy

protected abstract Object getMergePolicy(String dataStructureName)

Returns:

merge policy for the data structure

iteratorsOf

protected abstract Collection<Iterator<Store>> iteratorsOf(int partitionId)

Returns:

collection of iterators to scan data in the partition

newMergeRunnable

protected abstract Runnable newMergeRunnable(Map<String,Collection<Store>> collectedStores,
                                             Map<String,Collection<Store>> collectedStoresWithLegacyPolicies,
                                             Collection<Store> backupStores,
                                             NodeEngine nodeEngine)

Returns:

new merge runnable