org.gridgain.grid.kernal.processors.cache.datastructures

Class GridCacheDataStructuresImpl<K,V>

java.lang.Object

org.gridgain.grid.kernal.processors.cache.datastructures.GridCacheDataStructuresImpl<K,V>

All Implemented Interfaces:

GridCacheDataStructures

public class GridCacheDataStructuresImpl<K,V>
extends Object
implements GridCacheDataStructures

Data structures implementation object.

Constructor Summary

Constructors

Constructor and Description
GridCacheDataStructuresImpl(GridCacheContext<K,V> cctx)

Method Summary

Methods

Modifier and Type	Method and Description
GridCacheAtomicLong	atomicLong(String name, long initVal, boolean create) Will get a atomic long from cache and create one if it has not been created yet and create flag is true.
<T> GridCacheAtomicReference<T>	atomicReference(String name, T initVal, boolean create) Will get a atomic reference from cache and create one if it has not been created yet and create flag is true.
GridCacheAtomicSequence	atomicSequence(String name, long initVal, boolean create) Will get an atomic sequence from cache and create one if it has not been created yet and create flag is true.
<T,S> GridCacheAtomicStamped<T,S>	atomicStamped(String name, T initVal, S initStamp, boolean create) Will get a atomic stamped from cache and create one if it has not been created yet and create flag is true.
GridCacheCountDownLatch	countDownLatch(String name, int cnt, boolean autoDel, boolean create) Gets or creates count down latch.
<T> GridCacheQueue<T>	queue(String name, int cap, boolean collocated, boolean create) Will get a named queue from cache and create one if it has not been created yet and create flag is true.
boolean	removeAtomicLong(String name) Remove atomic long from cache.
boolean	removeAtomicReference(String name) Remove atomic reference from cache.
boolean	removeAtomicSequence(String name) Remove sequence from cache.
boolean	removeAtomicStamped(String name) Remove atomic stamped from cache.
boolean	removeCountDownLatch(String name) Removes count down latch from cache.
boolean	removeQueue(String name) Remove queue from cache.
boolean	removeQueue(String name, int batchSize) Remove queue from cache.
boolean	removeSet(String name) Removes set from cache.
<T> GridCacheSet<T>	set(String name, boolean collocated, boolean create) Will get a named set from cache and create one if it has not been created yet and create flag is true.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheDataStructuresImpl

public GridCacheDataStructuresImpl(GridCacheContext<K,V> cctx)

Parameters:

cctx - Cache context.

Method Detail

atomicSequence

public GridCacheAtomicSequence atomicSequence(String name,
                                     long initVal,
                                     boolean create)
                                       throws GridException

Will get an atomic sequence from cache and create one if it has not been created yet and create flag is true.

Specified by:

atomicSequence in interface GridCacheDataStructures

Parameters:

name - Sequence name.

initVal - Initial value for sequence. If sequence already cached, initVal will be ignored.

create - Boolean flag indicating whether data structure should be created if does not exist.

Returns:

Sequence for the given name.

Throws:

GridException - If sequence could not be fetched or created.

removeAtomicSequence

public boolean removeAtomicSequence(String name)
                             throws GridException

Remove sequence from cache.

Specified by:

removeAtomicSequence in interface GridCacheDataStructures

Parameters:

name - Sequence name.

Returns:

True if sequence has been removed, false otherwise.

Throws:

GridException - If remove failed.

atomicLong

public GridCacheAtomicLong atomicLong(String name,
                             long initVal,
                             boolean create)
                               throws GridException

Will get a atomic long from cache and create one if it has not been created yet and create flag is true.

Specified by:

atomicLong in interface GridCacheDataStructures

Parameters:

name - Name of atomic long.

initVal - Initial value for atomic long. If atomic long already cached, initVal will be ignored.

create - Boolean flag indicating whether data structure should be created if does not exist.

Returns:

Atomic long.

Throws:

GridException - If atomic long could not be fetched or created.

removeAtomicLong

public boolean removeAtomicLong(String name)
                         throws GridException

Remove atomic long from cache.

Specified by:

removeAtomicLong in interface GridCacheDataStructures

Parameters:

name - Name of atomic long.

Returns:

True if atomic long has been removed, false otherwise.

Throws:

GridException - If removing failed.

atomicReference

public <T> GridCacheAtomicReference<T> atomicReference(String name,
                                              T initVal,
                                              boolean create)
                                            throws GridException

Will get a atomic reference from cache and create one if it has not been created yet and create flag is true.

Specified by:

atomicReference in interface GridCacheDataStructures

Parameters:

name - Atomic reference name.

initVal - Initial value for atomic reference. If atomic reference already cached, initVal will be ignored.

create - Boolean flag indicating whether data structure should be created if does not exist.

Returns:

Atomic reference for the given name.

Throws:

GridException - If atomic reference could not be fetched or created.

removeAtomicReference

public boolean removeAtomicReference(String name)
                              throws GridException

Remove atomic reference from cache.

Specified by:

removeAtomicReference in interface GridCacheDataStructures

Parameters:

name - Atomic reference name.

Returns:

True if atomic reference has been removed, false otherwise.

Throws:

GridException - If remove failed.

atomicStamped

public <T,S> GridCacheAtomicStamped<T,S> atomicStamped(String name,
                                              T initVal,
                                              S initStamp,
                                              boolean create)
                                          throws GridException

Will get a atomic stamped from cache and create one if it has not been created yet and create flag is true.

Specified by:

atomicStamped in interface GridCacheDataStructures

Parameters:

name - Atomic stamped name.

initVal - Initial value for atomic stamped. If atomic stamped already cached, initVal will be ignored.

initStamp - Initial stamp for atomic stamped. If atomic stamped already cached, initStamp will be ignored.

create - Boolean flag indicating whether data structure should be created if does not exist.

Returns:

Atomic stamped for the given name.

Throws:

GridException - If atomic stamped could not be fetched or created.

removeAtomicStamped

public boolean removeAtomicStamped(String name)
                            throws GridException

Remove atomic stamped from cache.

Specified by:

removeAtomicStamped in interface GridCacheDataStructures

Parameters:

name - Atomic stamped name.

Returns:

True if atomic stamped has been removed, false otherwise.

Throws:

GridException - If remove failed.

queue

public <T> GridCacheQueue<T> queue(String name,
                          int cap,
                          boolean collocated,
                          boolean create)
                        throws GridException

Will get a named queue from cache and create one if it has not been created yet and create flag is true. If queue is present in cache already, queue properties will not be changed. Use collocation for GridCacheMode.PARTITIONED caches if you have lots of relatively small queues as it will make fetching, querying, and iteration a lot faster. If you have few very large queues, then you should consider turning off collocation as they simply may not fit in a single node's memory. However note that in this case to get a single element off the queue all nodes may have to be queried.

Specified by:

queue in interface GridCacheDataStructures

Parameters:

name - Name of queue.

cap - Capacity of queue, 0 for unbounded queue.

collocated - If true then all items within the same queue will be collocated on the same node. Otherwise elements of the same queue maybe be cached on different nodes. If you have lots of relatively small queues, then you should use collocation. If you have few large queues, then you should turn off collocation. This parameter works only for GridCacheMode.PARTITIONED cache.

create - Boolean flag indicating whether data structure should be created if does not exist.

Returns:

Queue with given properties.

Throws:

GridException - If remove failed.

removeQueue

public boolean removeQueue(String name)
                    throws GridException

Remove queue from cache. Internally one transaction will be created for all elements in the queue. If you anticipate that queue may be large, then it's better to use GridCacheDataStructures.removeQueue(String, int) which allows to specify batch size. In that case transaction will be split into multiple transactions which will have upto batchSize elements in it.

Specified by:

removeQueue in interface GridCacheDataStructures

Parameters:

name - Name queue.

Returns:

True if queue has been removed and false if it's not cached.

Throws:

GridException - If remove failed.

removeQueue

public boolean removeQueue(String name,
                  int batchSize)
                    throws GridException

Remove queue from cache. Internally multiple transactions will be created with no more than batchSize elements in them. For larger queues, this method is preferrable over GridCacheDataStructures.removeQueue(String) which will create only one transaction for the whole operation.

Specified by:

removeQueue in interface GridCacheDataStructures

Parameters:

name - Name queue.

batchSize - Batch size.

Returns:

True if queue has been removed and false if it's not cached.

Throws:

GridException - If remove failed.

set

@Nullable
public <T> GridCacheSet<T> set(String name,
                               boolean collocated,
                               boolean create)
                    throws GridException

Will get a named set from cache and create one if it has not been created yet and create flag is true.

Specified by:

set in interface GridCacheDataStructures

Parameters:

name - Set name.

collocated - If true then all items within the same set will be collocated on the same node. Otherwise elements of the same set maybe be cached on different nodes. This parameter works only for GridCacheMode.PARTITIONED cache.

create - Flag indicating whether set should be created if does not exist.

Returns:

Set with given properties.

Throws:

GridException - If failed.

removeSet

public boolean removeSet(String name)
                  throws GridException

Removes set from cache.

Specified by:

removeSet in interface GridCacheDataStructures

Parameters:

name - Set name.

Returns:

True if set has been removed and false if it's not cached.

Throws:

GridException - If failed.

countDownLatch

@Nullable
public GridCacheCountDownLatch countDownLatch(String name,
                                              int cnt,
                                              boolean autoDel,
                                              boolean create)
                                       throws GridException

Gets or creates count down latch. If count down latch is not found in cache and create flag is true, it is created using provided name and count parameter.

Specified by:

countDownLatch in interface GridCacheDataStructures

Parameters:

name - Name of the latch.

cnt - Count for new latch creation.

autoDel - True to automatically delete latch from cache when its count reaches zero.

create - Boolean flag indicating whether data structure should be created if does not exist.

Returns:

Count down latch for the given name.

Throws:

GridException - If operation failed.

removeCountDownLatch

public boolean removeCountDownLatch(String name)
                             throws GridException

Removes count down latch from cache.

Specified by:

removeCountDownLatch in interface GridCacheDataStructures

Parameters:

name - Name of the latch.

Returns:

Count down latch for the given name.

Throws:

GridException - If operation failed.