Package org.infinispan.query.dsl.embedded.impl

Class BaseIckleFilterIndexingServiceProvider

java.lang.Object

org.infinispan.query.dsl.embedded.impl.BaseIckleFilterIndexingServiceProvider

All Implemented Interfaces:

FilterIndexingServiceProvider

Direct Known Subclasses:

IckleContinuousQueryFilterIndexingServiceProvider, IckleFilterIndexingServiceProvider

public abstract class BaseIckleFilterIndexingServiceProvider
extends Object
implements FilterIndexingServiceProvider

Since:

8.1

Author:

anistor@redhat.com

Constructor Summary

Constructors

Constructor	Description
BaseIckleFilterIndexingServiceProvider()

Method Summary

Modifier and Type	Method	Description
protected abstract Matcher	getMatcher(IndexedFilter<?,?,?> indexedFilter)
protected abstract Map<String,Object>	getNamedParameters(IndexedFilter<?,?,?> indexedFilter)
protected abstract String	getQueryString(IndexedFilter<?,?,?> indexedFilter)
protected void	injectDependencies(CacheNotifier cacheNotifier, ClusteringDependentLogic clusteringDependentLogic)
<K,V> DelegatingCacheEntryListenerInvocation<K,V>	interceptListenerInvocation(CacheEntryListenerInvocation<K,V> invocation)	Starts handling an invocation that uses an IndexedFilter.
protected abstract boolean	isDelta(IndexedFilter<?,?,?> indexedFilter)
protected abstract Object	makeFilterResult(Object userContext, Object eventType, Object key, Object instance, Object[] projection, Comparable[] sortProjection)
protected abstract <K,V> void	matchEvent(EventWrapper<K,V,CacheEntryEvent<K,V>> eventWrapper, Matcher matcher)
<K,V> void	registerListenerInvocations(boolean isClustered, boolean isPrimaryOnly, boolean filterAndConvert, IndexedFilter<?,?,?> indexedFilter, Map<Class<? extends Annotation>,List<DelegatingCacheEntryListenerInvocation<K,V>>> listeners, DataConversion keyDataConversion, DataConversion valueDataConversion)
void	start()	Start the provider.
void	stop()	Stop the provider.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.notifications.cachelistener.filter.FilterIndexingServiceProvider

supportsFilter

Constructor Detail

BaseIckleFilterIndexingServiceProvider

public BaseIckleFilterIndexingServiceProvider()

Method Detail

injectDependencies

protected void injectDependencies(CacheNotifier cacheNotifier,
                                  ClusteringDependentLogic clusteringDependentLogic)

start

public void start()

Description copied from interface: FilterIndexingServiceProvider

Start the provider. This is called after the dependencies are injected.

Specified by:

start in interface FilterIndexingServiceProvider

stop

public void stop()

Description copied from interface: FilterIndexingServiceProvider

Stop the provider.

Specified by:

stop in interface FilterIndexingServiceProvider

interceptListenerInvocation

public <K,V> DelegatingCacheEntryListenerInvocation<K,V> interceptListenerInvocation(CacheEntryListenerInvocation<K,V> invocation)

Description copied from interface: FilterIndexingServiceProvider

Starts handling an invocation that uses an IndexedFilter.

Specified by:

interceptListenerInvocation in interface FilterIndexingServiceProvider

Type Parameters:

K - cache key type

V - cache value type

Parameters:

invocation - the invocation to handle

Returns:

the wrapped invocation

registerListenerInvocations

public <K,V> void registerListenerInvocations(boolean isClustered,
                                                    boolean isPrimaryOnly,
                                                    boolean filterAndConvert,
                                                    IndexedFilter<?,?,?> indexedFilter,
                                                    Map<Class<? extends Annotation>,List<DelegatingCacheEntryListenerInvocation<K,V>>> listeners,
                                                    DataConversion keyDataConversion,
                                                    DataConversion valueDataConversion)

Specified by:

registerListenerInvocations in interface FilterIndexingServiceProvider

getMatcher

protected abstract Matcher getMatcher(IndexedFilter<?,?,?> indexedFilter)

getQueryString

protected abstract String getQueryString(IndexedFilter<?,?,?> indexedFilter)

getNamedParameters

protected abstract Map<String,Object> getNamedParameters(IndexedFilter<?,?,?> indexedFilter)

isDelta

protected abstract boolean isDelta(IndexedFilter<?,?,?> indexedFilter)

matchEvent

protected abstract <K,V> void matchEvent(EventWrapper<K,V,CacheEntryEvent<K,V>> eventWrapper,
                                               Matcher matcher)

makeFilterResult

protected abstract Object makeFilterResult(Object userContext,
                                           Object eventType,
                                           Object key,
                                           Object instance,
                                           Object[] projection,
                                           Comparable[] sortProjection)