org.apache.ignite.internal.processors.cache

Class CacheWeakQueryIteratorsHolder<V>

java.lang.Object

org.apache.ignite.internal.processors.cache.CacheWeakQueryIteratorsHolder<V>

Type Parameters:

V - Type for cache query future.

public class CacheWeakQueryIteratorsHolder<V>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	CacheWeakQueryIteratorsHolder.WeakQueryCloseableIterator<T>
static interface	CacheWeakQueryIteratorsHolder.WeakReferenceCloseableIterator<T>

Constructor Summary

Constructors

Constructor and Description
CacheWeakQueryIteratorsHolder(IgniteLogger log)

Method Summary

Methods

Modifier and Type	Method and Description
void	checkWeakQueue() Closes unreachable iterators.
void	clearQueries() Cancel all cache queries.
<T> CacheWeakQueryIteratorsHolder.WeakReferenceCloseableIterator<T>	iterator(CacheQueryFuture<V> fut, CacheIteratorConverter<T,V> convert)
<T> CacheWeakQueryIteratorsHolder.WeakReferenceCloseableIterator<T>	iterator(GridCloseableIterator<V> iter, CacheIteratorConverter<T,V> convert)
void	removeIterator(CacheWeakQueryIteratorsHolder.WeakReferenceCloseableIterator it)

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheWeakQueryIteratorsHolder

public CacheWeakQueryIteratorsHolder(IgniteLogger log)

Parameters:

log - Logger.

Method Detail

iterator

public <T> CacheWeakQueryIteratorsHolder.WeakReferenceCloseableIterator<T> iterator(CacheQueryFuture<V> fut,
                                                                           CacheIteratorConverter<T,V> convert)

Type Parameters:

T - Type for the iterator.

Parameters:

fut - Query to iterate.

convert - Cache iterator converter.

Returns:

Iterator over the cache.

iterator

public <T> CacheWeakQueryIteratorsHolder.WeakReferenceCloseableIterator<T> iterator(GridCloseableIterator<V> iter,
                                                                           CacheIteratorConverter<T,V> convert)

Type Parameters:

T - Type for the iterator.

Parameters:

iter - Closeable iterator.

Returns:

Iterator over the cache.

removeIterator

public void removeIterator(CacheWeakQueryIteratorsHolder.WeakReferenceCloseableIterator it)
                    throws IgniteCheckedException

Parameters:

it - Iterator.

Throws:

IgniteCheckedException - If failed.

checkWeakQueue

public void checkWeakQueue()

Closes unreachable iterators.

clearQueries

public void clearQueries()

Cancel all cache queries.