com.hazelcast.spi.impl.merge

Class AbstractContainerMerger<C,V,T extends MergingValue<V>>

java.lang.Object

com.hazelcast.spi.impl.merge.AbstractContainerMerger<C,V,T>

Type Parameters:

C - container of the data structure

V - the type of the merged value

T - the type of the merging value, e.g. MergingValue or MergingEntry & MergingHits

All Implemented Interfaces:

Runnable

public abstract class AbstractContainerMerger<C,V,T extends MergingValue<V>>
extends Object
implements Runnable

Merges data structures which have been collected via an AbstractContainerCollector.

Field Summary

Fields

Modifier and Type	Field and Description
protected AbstractContainerCollector<C>	collector

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractContainerMerger(AbstractContainerCollector<C> collector, NodeEngine nodeEngine)

Method Summary

Modifier and Type	Method and Description
protected abstract String	getLabel() Returns a label of the service for customized error messages.
protected SplitBrainMergePolicy<V,T>	getMergePolicy(MergePolicyConfig mergePolicyConfig) Returns the SplitBrainMergePolicy instance of a given MergePolicyConfig.
protected void	invoke(String serviceName, Operation operation, int partitionId) Invokes the given merge operation.
void	run()
protected abstract void	runInternal() Executes the service specific merging logic.

Methods inherited from class java.lang.Object

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

Field Detail

collector

protected final AbstractContainerCollector<C> collector

Constructor Detail

AbstractContainerMerger

protected AbstractContainerMerger(AbstractContainerCollector<C> collector,
                                  NodeEngine nodeEngine)

Method Detail

run

public final void run()

Specified by:

run in interface Runnable

getLabel

protected abstract String getLabel()

Returns a label of the service for customized error messages.

runInternal

protected abstract void runInternal()

Executes the service specific merging logic.

getMergePolicy

protected SplitBrainMergePolicy<V,T> getMergePolicy(MergePolicyConfig mergePolicyConfig)

Returns the SplitBrainMergePolicy instance of a given MergePolicyConfig.

Parameters:

mergePolicyConfig - the MergePolicyConfig to retrieve the merge policy from

Returns:

the SplitBrainMergePolicy instance

invoke

protected void invoke(String serviceName,
                      Operation operation,
                      int partitionId)

Invokes the given merge operation.

Parameters:

serviceName - the service name

operation - the merge operation

partitionId - the partition ID of the operation