Package org.infinispan.query.continuous.impl

Class IckleContinuousQueryFilterIndexingServiceProvider

java.lang.Object

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

org.infinispan.query.continuous.impl.IckleContinuousQueryFilterIndexingServiceProvider

All Implemented Interfaces:

FilterIndexingServiceProvider

@MetaInfServices(FilterIndexingServiceProvider.class)
public class IckleContinuousQueryFilterIndexingServiceProvider
extends BaseIckleFilterIndexingServiceProvider

Since:

8.1

Author:

anistor@redhat.com

Constructor Summary

Constructors

Modifier	Constructor	Description
	IckleContinuousQueryFilterIndexingServiceProvider()
protected	IckleContinuousQueryFilterIndexingServiceProvider(Object joiningEvent, Object updatedEvent, Object leavingEvent)

Method Summary

Modifier and Type	Method	Description
protected Matcher	getMatcher(IndexedFilter<?,?,?> indexedFilter)
protected Map<String,Object>	getNamedParameters(IndexedFilter<?,?,?> indexedFilter)
protected String	getQueryString(IndexedFilter<?,?,?> indexedFilter)
protected boolean	isDelta(IndexedFilter<?,?,?> indexedFilter)
protected Object	makeFilterResult(Object userContext, Object eventType, Object key, Object instance, Object[] projection, Comparable[] sortProjection)
protected <K,V> void	matchEvent(EventWrapper<K,V,CacheEntryEvent<K,V>> eventWrapper, Matcher matcher)
boolean	supportsFilter(IndexedFilter<?,?,?> indexedFilter)	Reports whether this provider supports the given filter type.

Methods inherited from class org.infinispan.query.dsl.embedded.impl.BaseIckleFilterIndexingServiceProvider

injectDependencies, interceptListenerInvocation, registerListenerInvocations, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

IckleContinuousQueryFilterIndexingServiceProvider

public IckleContinuousQueryFilterIndexingServiceProvider()

IckleContinuousQueryFilterIndexingServiceProvider

protected IckleContinuousQueryFilterIndexingServiceProvider(Object joiningEvent,
                                                            Object updatedEvent,
                                                            Object leavingEvent)

Method Detail

supportsFilter

public boolean supportsFilter(IndexedFilter<?,?,?> indexedFilter)

Description copied from interface: FilterIndexingServiceProvider

Reports whether this provider supports the given filter type.

Parameters:

indexedFilter - an indexable filter

Returns:

true if the filter is supported, false otherwise

getMatcher

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

Specified by:

getMatcher in class BaseIckleFilterIndexingServiceProvider

getQueryString

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

Specified by:

getQueryString in class BaseIckleFilterIndexingServiceProvider

getNamedParameters

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

Specified by:

getNamedParameters in class BaseIckleFilterIndexingServiceProvider

isDelta

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

Specified by:

isDelta in class BaseIckleFilterIndexingServiceProvider

matchEvent

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

Specified by:

matchEvent in class BaseIckleFilterIndexingServiceProvider

makeFilterResult

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

Specified by:

makeFilterResult in class BaseIckleFilterIndexingServiceProvider