All Methods Instance Methods Concrete Methods
Modifier and Type |
Method and Description |
String |
addEventListener(EntryListener entryListener,
EventFilter eventFilter,
String mapName) |
String |
addInterceptor(String mapName,
MapInterceptor interceptor) |
String |
addLocalEventListener(EntryListener entryListener,
EventFilter eventFilter,
String mapName) |
String |
addLocalEventListener(EntryListener entryListener,
String mapName) |
void |
applyRecordInfo(Record record,
String mapName,
RecordInfo replicationInfo) |
void |
beforeMigration(PartitionMigrationEvent event) |
void |
clearNearCache(String mapName) |
void |
clearPartitionReplica(int partitionId) |
void |
commitMigration(PartitionMigrationEvent event) |
boolean |
compare(String mapName,
Object value1,
Object value2) |
MapProxyImpl |
createDistributedObject(String name) |
LocalMapStatsImpl |
createLocalMapStats(String mapName) |
Record |
createRecord(String name,
Data dataKey,
Object value,
long ttl) |
Record |
createRecord(String name,
Data dataKey,
Object value,
long ttl,
boolean shouldSchedule) |
RecordInfo |
createRecordInfo(MapContainer mapContainer,
Record record) |
RecordReplicationInfo |
createRecordReplicationInfo(MapContainer mapContainer,
Record record) |
<K,V> SimpleEntryView<K,V> |
createSimpleEntryView(K key,
V value,
Record record) |
TransactionalMapProxy |
createTransactionalObject(String name,
TransactionSupport transaction) |
void |
destroyDistributedObject(String name) |
void |
dispatchEvent(EventData eventData,
EntryListener listener) |
long |
findDelayMillis(ScheduledEntry entry) |
RecordStore |
getExistingRecordStore(int partitionId,
String mapName) |
Object |
getFromNearCache(String mapName,
Data key) |
LocalMapStatsImpl |
getLocalMapStatsImpl(String name) |
MapContainer |
getMapContainer(String mapName) |
Map<String,MapContainer> |
getMapContainers() |
MapMergePolicy |
getMergePolicy(String mergePolicyName) |
NearCache |
getNearCache(String mapName) |
NodeEngine |
getNodeEngine() |
List<Integer> |
getOwnedPartitions() |
PartitionContainer |
getPartitionContainer(int partitionId) |
Operation |
getPostJoinOperation()
Post join operations must be lock free; means no locks at all;
no partition locks, no key-based locks, no service level locks!
Post join operations should return response, at least a null response.
|
RecordStore |
getRecordStore(int partitionId,
String mapName) |
SerializationService |
getSerializationService() |
void |
init(NodeEngine nodeEngine,
Properties properties)
Initializes the ManagedService
|
void |
interceptAfterGet(String mapName,
Object value) |
void |
interceptAfterPut(String mapName,
Object newValue) |
void |
interceptAfterRemove(String mapName,
Object value) |
Object |
interceptGet(String mapName,
Object value) |
Object |
interceptPut(String mapName,
Object oldValue,
Object newValue) |
Object |
interceptRemove(String mapName,
Object value) |
void |
invalidateAllNearCaches(String mapName,
Data key) |
void |
invalidateAllNearCaches(String mapName,
Set<Data> keys) |
void |
invalidateNearCache(String mapName,
Data key) |
void |
invalidateNearCache(String mapName,
Set<Data> keys) |
boolean |
isNearCacheAndInvalidationEnabled(String mapName) |
boolean |
isNearCacheEnabled(String mapName) |
void |
onReplicationEvent(WanReplicationEvent replicationEvent) |
Runnable |
prepareMergeRunnable() |
Operation |
prepareReplicationOperation(PartitionReplicationEvent event) |
void |
publishEvent(Address caller,
String mapName,
EntryEventType eventType,
Data dataKey,
Data dataOldValue,
Data dataValue) |
void |
publishWanReplicationRemove(String mapName,
Data key,
long removeTime) |
void |
publishWanReplicationUpdate(String mapName,
EntryView entryView) |
Object |
putNearCache(String mapName,
Data key,
Data value) |
QueryResult |
queryOnPartition(String mapName,
Predicate predicate,
int partitionId) |
boolean |
removeEventListener(String mapName,
String registrationId) |
void |
removeInterceptor(String mapName,
String id) |
void |
reset()
reset service, back to initial state
|
void |
rollbackMigration(PartitionMigrationEvent event) |
void |
rollbackTransaction(String transactionId) |
void |
scheduleIdleEviction(String mapName,
Data key,
long delay) |
void |
scheduleMapStoreDelete(String mapName,
Data key,
long delay) |
void |
scheduleMapStoreWrite(String mapName,
Data key,
Object value,
long delay) |
void |
scheduleTtlEviction(String mapName,
Record record,
long delay) |
void |
shutdown(boolean terminate)
Shuts down the ManagedService.
|
Data |
toData(Object object) |
Data |
toData(Object object,
PartitioningStrategy partitionStrategy) |
Object |
toObject(Object data) |