public interface EnterpriseMapCodecTemplate
Modifier and Type | Method and Description |
---|---|
Object |
addListener(String listenerName,
boolean localOnly) |
Object |
destroyCache(String mapName,
String cacheName) |
Object |
madePublishable(String mapName,
String cacheName) |
Object |
publisherCreate(String mapName,
String cacheName,
Data predicate,
int batchSize,
int bufferSize,
long delaySeconds,
boolean populate,
boolean coalesce) |
Object |
publisherCreateWithValue(String mapName,
String cacheName,
Data predicate,
int batchSize,
int bufferSize,
long delaySeconds,
boolean populate,
boolean coalesce) |
Object |
setReadCursor(String mapName,
String cacheName,
long sequence)
This method can be used to recover from a possible event loss situation.
|
Object publisherCreateWithValue(String mapName, String cacheName, Data predicate, int batchSize, int bufferSize, long delaySeconds, boolean populate, boolean coalesce)
mapName
- Name of the map.cacheName
- Name of the cache for query cache.predicate
- The predicate to filter events which will be applied to the QueryCache.batchSize
- The size of batch. After reaching this minimum size, node immediately sends buffered events to QueryCache.bufferSize
- Maximum number of events which can be stored in a buffer of partition.delaySeconds
- The minimum number of delay seconds which an event waits in the buffer of node.populate
- Flag to enable/disable initial population of the QueryCache.coalesce
- Flag to enable/disable coalescing. If true, then only the last updated value for a key is placed in the
batch, otherwise all changed values are included in the update.Object publisherCreate(String mapName, String cacheName, Data predicate, int batchSize, int bufferSize, long delaySeconds, boolean populate, boolean coalesce)
mapName
- Name of the map.cacheName
- Name of query cache.predicate
- The predicate to filter events which will be applied to the QueryCache.batchSize
- The size of batch. After reaching this minimum size, node immediately sends buffered events to QueryCache.bufferSize
- Maximum number of events which can be stored in a buffer of partition.delaySeconds
- The minimum number of delay seconds which an event waits in the buffer of node.populate
- Flag to enable/disable initial population of the QueryCache.coalesce
- Flag to enable/disable coalescing. If true, then only the last updated value for a key is placed in the
batch, otherwise all changed values are included in the update.Object madePublishable(String mapName, String cacheName)
mapName
- Name of the map.cacheName
- Name of query cache.Object addListener(String listenerName, boolean localOnly)
listenerName
- Name of the MapListener which will be used to listen this QueryCachelocalOnly
- if true fires events that originated from this node only, otherwise fires all eventsObject setReadCursor(String mapName, String cacheName, long sequence)
mapName
- Name of the map.cacheName
- Name of query cache.sequence
- The cursor position of the accumulator to be set.Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.