com.hazelcast.client.spi.ClientProxy
com.hazelcast.client.proxy.ClientMultiMapProxy<K,V>
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Object
public class ClientMultiMapProxy<K,V>
| Field Summary | |
|---|---|
protected static String |
NULL_KEY_IS_NOT_ALLOWED
|
protected static String |
NULL_VALUE_IS_NOT_ALLOWED
|
| Constructor Summary | |
|---|---|
ClientMultiMapProxy(String serviceName,
String name)
|
|
| Method Summary | ||
|---|---|---|
String |
addEntryListener(EntryListener<K,V> listener,
boolean includeValue)
Adds an entry listener for this multimap. |
|
String |
addEntryListener(EntryListener<K,V> listener,
K key,
boolean includeValue)
Adds the specified entry listener for the specified key. |
|
String |
addLocalEntryListener(EntryListener<K,V> listener)
Adds a local entry listener for this multimap. |
|
|
aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation)
Executes a predefined aggregation on the multimaps data set. |
|
|
aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation,
JobTracker jobTracker)
Executes a predefined aggregation on the multimaps data set. |
|
void |
clear()
Clears the multimap. |
|
boolean |
containsEntry(K key,
V value)
Returns whether the multimap contains the given key-value pair. |
|
boolean |
containsKey(K key)
Returns whether the multimap contains an entry with the key. |
|
boolean |
containsValue(Object value)
Returns whether the multimap contains an entry with the value. |
|
Set<Map.Entry<K,V>> |
entrySet()
Returns the set of key-value pairs in the multimap. |
|
void |
forceUnlock(K key)
Releases the lock for the specified key regardless of the lock owner. |
|
Collection<V> |
get(K key)
Returns the collection of values associated with the key. |
|
LocalMultiMapStats |
getLocalMultiMapStats()
Returns LocalMultiMapStats for this map. |
|
protected long |
getTimeInMillis(long time,
TimeUnit timeunit)
|
|
boolean |
isLocked(K key)
Checks the lock for the specified key. |
|
Set<K> |
keySet()
Returns the set of keys in the multimap. |
|
Set<K> |
localKeySet()
Returns the locally owned set of keys. |
|
void |
lock(K key)
Acquires a lock for the specified key. |
|
void |
lock(K key,
long leaseTime,
TimeUnit timeUnit)
Acquires the lock for the specified key for the specified lease time. |
|
protected void |
onDestroy()
Called before proxy is destroyed. |
|
boolean |
put(K key,
V value)
Stores a key-value pair in the multimap. |
|
Collection<V> |
remove(Object key)
Removes all the entries with the given key. |
|
boolean |
remove(Object key,
Object value)
Removes the given key value pair from the multimap. |
|
boolean |
removeEntryListener(String registrationId)
Removes the specified entry listener. |
|
int |
size()
Returns the number of key-value pairs in the multimap. |
|
String |
toString()
|
|
boolean |
tryLock(K key)
Tries to acquire the lock for the specified key. |
|
boolean |
tryLock(K key,
long time,
TimeUnit timeunit)
Tries to acquire the lock for the specified key. |
|
void |
unlock(K key)
Releases the lock for the specified key. |
|
int |
valueCount(K key)
Returns the number of values that match the given key in the multimap. |
|
Collection<V> |
values()
Returns the collection of values in the multimap. |
|
| Methods inherited from class com.hazelcast.client.spi.ClientProxy |
|---|
destroy, equals, getContext, getId, getName, getPartitionKey, getServiceName, hashCode, invoke, invoke, invoke, invokeInterruptibly, listen, listen, onInitialize, onShutdown, setContext, stopListening, throwExceptionIfNull, toData, toObject |
| Methods inherited from class java.lang.Object |
|---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
| Methods inherited from interface com.hazelcast.core.MultiMap |
|---|
getName |
| Methods inherited from interface com.hazelcast.core.DistributedObject |
|---|
destroy, getId, getPartitionKey, getServiceName |
| Field Detail |
|---|
protected static final String NULL_KEY_IS_NOT_ALLOWED
protected static final String NULL_VALUE_IS_NOT_ALLOWED
| Constructor Detail |
|---|
public ClientMultiMapProxy(String serviceName,
String name)
| Method Detail |
|---|
public boolean put(K key,
V value)
MultiMapWarning:
This method uses hashCode and equals of the binary form of the key, not the actual implementations of hashCode and equals defined in the key's class.
put in interface BaseMultiMap<K,V>put in interface MultiMap<K,V>key - the key to be storedvalue - the value to be stored
public Collection<V> get(K key)
MultiMapWarning:
This method uses hashCode and equals of the binary form of the key, not the actual implementations of hashCode and equals defined in the key's class.
Warning-2:
The collection is NOT backed by the map, so changes to the map are NOT reflected in the collection, and vice-versa.
get in interface BaseMultiMap<K,V>get in interface MultiMap<K,V>key - the key whose associated values are to be returned
public boolean remove(Object key,
Object value)
MultiMapWarning:
This method uses hashCode and equals of the binary form of the key, not the actual implementations of hashCode and equals defined in the key's class.
remove in interface BaseMultiMap<K,V>remove in interface MultiMap<K,V>key - the key of the entry to removevalue - the value of the entry to remove
public Collection<V> remove(Object key)
MultiMapWarning:
This method uses hashCode and equals of the binary form of the key, not the actual implementations of hashCode and equals defined in the key's class.
Warning-2:
The collection is NOT backed by the map, so changes to the map are NOT reflected in the collection, and vice-versa.
remove in interface BaseMultiMap<K,V>remove in interface MultiMap<K,V>key - the key of the entries to remove
public Set<K> localKeySet()
MultiMapWarning:
The set is NOT backed by the map, so changes to the map are NOT reflected in the set, and vice-versa.
localKeySet in interface MultiMap<K,V>public Set<K> keySet()
MultiMapWarning:
The set is NOT backed by the map, so changes to the map are NOT reflected in the set, and vice-versa.
keySet in interface MultiMap<K,V>public Collection<V> values()
MultiMapWarning:
The collection is NOT backed by the map, so changes to the map are NOT reflected in the collection, and vice-versa.
values in interface MultiMap<K,V>public Set<Map.Entry<K,V>> entrySet()
MultiMapWarning:
The set is NOT backed by the map, so changes to the map are NOT reflected in the set, and vice-versa.
entrySet in interface MultiMap<K,V>public boolean containsKey(K key)
MultiMapWarning:
This method uses hashCode and equals of the binary form of the key, not the actual implementations of hashCode and equals defined in the key's class.
containsKey in interface MultiMap<K,V>key - the key whose existence is checked.
public boolean containsValue(Object value)
MultiMap
containsValue in interface MultiMap<K,V>value - the value whose existence is checked.
public boolean containsEntry(K key,
V value)
MultiMap
containsEntry in interface MultiMap<K,V>key - the key whose existence is checked.value - the value whose existence is checked.
public int size()
MultiMap
size in interface BaseMultiMap<K,V>size in interface MultiMap<K,V>public void clear()
MultiMap
clear in interface MultiMap<K,V>public int valueCount(K key)
MultiMapWarning:
This method uses hashCode and equals of the binary form of the key, not the actual implementations of hashCode and equals defined in the key's class.
valueCount in interface BaseMultiMap<K,V>valueCount in interface MultiMap<K,V>key - the key whose values count is to be returned
public String addLocalEntryListener(EntryListener<K,V> listener)
MultiMapmultimap.put(key2, value2).
If the key2 is owned by member2, then the local listener will be
notified for the add/update event. Also note that entries can migrate to
other nodes for load balancing and/or membership change.
addLocalEntryListener in interface MultiMap<K,V>listener - entry listener for this multimap
MultiMap.localKeySet()
public String addEntryListener(EntryListener<K,V> listener,
boolean includeValue)
MultiMap
addEntryListener in interface MultiMap<K,V>listener - entry listener for this multimapincludeValue - true if EntryEvent should
contain the value, false otherwise
public boolean removeEntryListener(String registrationId)
MultiMap
removeEntryListener in interface MultiMap<K,V>registrationId - registration id of listener
public String addEntryListener(EntryListener<K,V> listener,
K key,
boolean includeValue)
MultiMapWarning:
This method uses hashCode and equals of the binary form of the key, not the actual implementations of hashCode and equals defined in the key's class.
addEntryListener in interface MultiMap<K,V>listener - the entry listenerkey - the key to listen toincludeValue - true if EntryEvent should
contain the value, false otherwise
public void lock(K key)
MultiMapIf the lock is not available, then the current thread becomes disabled for thread scheduling purposes and lies dormant until the lock has been acquired.
The scope of the lock is for this multimap only. The acquired lock is only for the key in this multimap. Locks are re-entrant, so if the key is locked N times, then it should be unlocked N times before another thread can acquire it.Warning:
This method uses hashCode and equals of the binary form of the key, not the actual implementations of hashCode and equals defined in the key's class.
lock in interface MultiMap<K,V>key - the key to lock.
public void lock(K key,
long leaseTime,
TimeUnit timeUnit)
MultiMapAfter the lease time, the lock will be released.
If the lock is not available, then the current thread becomes disabled for thread scheduling purposes and lies dormant until the lock has been acquired.
Scope of the lock is for this map only. The acquired lock is only for the key in this map. Locks are re-entrant, so if the key is locked N times, then it should be unlocked N times before another thread can acquire it.Warning:
This method uses hashCode and equals of the binary form of the key, not the actual implementations of hashCode and equals defined in the key's class.
lock in interface MultiMap<K,V>key - the key to lock.leaseTime - time to wait before releasing the lock.timeUnit - unit of time for the lease time.public boolean isLocked(K key)
MultiMapIf the lock is acquired, this method returns true, else it returns false.
Warning:
This method uses hashCode and equals of the binary form of the key, not the actual implementations of hashCode and equals defined in the key's class.
isLocked in interface MultiMap<K,V>key - key to lock to be checked.
public boolean tryLock(K key)
MultiMapIf the lock is not available, then the current thread does not wait and the method returns false immediately.
Warning:
This method uses hashCode and equals of the binary form of the key, not the actual implementations of hashCode and equals defined in the key's class.
tryLock in interface MultiMap<K,V>key - the key to lock.
public boolean tryLock(K key,
long time,
TimeUnit timeunit)
throws InterruptedException
MultiMapIf the lock is not available, then the current thread becomes disabled for thread scheduling purposes and lies dormant until one of two things happens:
Warning:
This method uses hashCode and equals of the binary form of the key, not the actual implementations of hashCode and equals defined in the key's class.
tryLock in interface MultiMap<K,V>time - the maximum time to wait for the locktimeunit - the time unit of the time argument
InterruptedExceptionpublic void unlock(K key)
MultiMapWarning:
This method uses hashCode and equals of the binary form of the key, not the actual implementations of hashCode and equals defined in the key's class.
unlock in interface MultiMap<K,V>key - the key to lock.public void forceUnlock(K key)
MultiMapWarning:
This method uses hashCode and equals of binary form of the key, not the actual implementations of hashCode and equals defined in key's class.
forceUnlock in interface MultiMap<K,V>key - key to lock.public LocalMultiMapStats getLocalMultiMapStats()
MultiMapLocalMapStats
from all members of the cluster and combine them.
getLocalMultiMapStats in interface MultiMap<K,V>
public <SuppliedValue,Result> Result aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation)
MultiMapSupplier
is used to either select or to select and extract a (sub-)value. A predefined set of aggregations can be found in
Aggregations.
aggregate in interface MultiMap<K,V>SuppliedValue - the final type emitted from the supplierResult - the resulting aggregation value typesupplier - the supplier to select and / or extract a (sub-)value from the multimapaggregation - the aggregation that is being executed against the multimap
public <SuppliedValue,Result> Result aggregate(Supplier<K,V,SuppliedValue> supplier,
Aggregation<K,SuppliedValue,Result> aggregation,
JobTracker jobTracker)
MultiMapSupplier
is used to either select, or to select and extract, a (sub-)value. A predefined set of aggregations can be found in
Aggregations.
aggregate in interface MultiMap<K,V>SuppliedValue - the final type emitted from the supplierResult - the resulting aggregation value typesupplier - the supplier to select and / or extract a (sub-)value from the multimapaggregation - the aggregation that is being executed against the multimapjobTracker - the JobTracker instance to execute the aggregation
protected void onDestroy()
ClientProxy
onDestroy in class ClientProxy
protected long getTimeInMillis(long time,
TimeUnit timeunit)
public String toString()
toString in class Object
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||