com.hazelcast.replicatedmap.impl

Class ReplicatedMapEvictionProcessor

java.lang.Object

com.hazelcast.replicatedmap.impl.ReplicatedMapEvictionProcessor

All Implemented Interfaces:

ScheduledEntryProcessor<Object,Object>

public class ReplicatedMapEvictionProcessor
extends Object
implements ScheduledEntryProcessor<Object,Object>

Actual eviction processor implementation to remove values to evict values from the replicated map

Constructor Summary

Constructors

Constructor and Description
ReplicatedMapEvictionProcessor(ReplicatedRecordStore store, NodeEngine nodeEngine, int partitionId)

Method Summary

Modifier and Type	Method and Description
void	process(EntryTaskScheduler<Object,Object> scheduler, Collection<ScheduledEntry<Object,Object>> entries) Processes all entries.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicatedMapEvictionProcessor

public ReplicatedMapEvictionProcessor(ReplicatedRecordStore store,
                                      NodeEngine nodeEngine,
                                      int partitionId)

Method Detail

process

public void process(EntryTaskScheduler<Object,Object> scheduler,
                    Collection<ScheduledEntry<Object,Object>> entries)

Description copied from interface: ScheduledEntryProcessor

Processes all entries. Implementation has to handle the failures and can possibly reschedule for a future time. Imagine you are implementing this for dirty records: if mapStore.storeAll throws an exception, you might want to reschedule the failed records.

Specified by:

process in interface ScheduledEntryProcessor<Object,Object>

Parameters:

scheduler - the EntryTskScheduler

entries - the entries (key and value) to process