com.hazelcast.spi.impl.merge

Class AbstractNamedContainerCollector<C>

java.lang.Object

com.hazelcast.spi.impl.merge.AbstractContainerCollector<C>

com.hazelcast.spi.impl.merge.AbstractNamedContainerCollector<C>

Type Parameters:

C - container of the data structure

public abstract class AbstractNamedContainerCollector<C>
extends AbstractContainerCollector<C>

Base implementation of AbstractContainerCollector for data structures which reference their containers by name.

Nested Class Summary

Nested classes/interfaces inherited from class com.hazelcast.spi.impl.merge.AbstractContainerCollector

AbstractContainerCollector.EmptyIterator

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<String,C>	containers

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractNamedContainerCollector(NodeEngine nodeEngine, ConcurrentMap<String,C> containers)

Method Summary

Modifier and Type	Method and Description
protected Iterator<C>	containerIterator(int partitionId) Returns all containers of the data structure for the given partition ID.
protected void	onIteration(String containerName, C container) Will be called by ContainerIterator#hasNext().

Methods inherited from class com.hazelcast.spi.impl.merge.AbstractContainerCollector

destroy, destroy, destroyBackup, getCollectedContainers, getMergePolicyConfig, getMergingValueCount, isMergeable, onDestroy, run

Methods inherited from class java.lang.Object

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

Field Detail

containers

protected final ConcurrentMap<String,C> containers

Constructor Detail

AbstractNamedContainerCollector

protected AbstractNamedContainerCollector(NodeEngine nodeEngine,
                                          ConcurrentMap<String,C> containers)

Method Detail

containerIterator

protected final Iterator<C> containerIterator(int partitionId)

Description copied from class: AbstractContainerCollector

Returns all containers of the data structure for the given partition ID.

Specified by:

containerIterator in class AbstractContainerCollector<C>

Returns:

Iterator over the containers of the given partition

onIteration

protected void onIteration(String containerName,
                           C container)

Will be called by ContainerIterator#hasNext().

Can be overridden by implementations to save the relation between container name and container.

Parameters:

containerName - the name of the removed container

container - the removed container