Package org.infinispan.query.remote.impl

Interface RemoteQueryManager

public interface RemoteQueryManager

Manages components used during indexed and index-less query.

Since:

9.2

Field Summary

Fields

Modifier and Type	Field	Description
static org.infinispan.commons.dataconversion.MediaType	PROTOSTREAM_UNWRAPPED
static org.infinispan.commons.dataconversion.MediaType	QUERY_REQUEST_TYPE

Method Summary

Modifier and Type	Method	Description
Object	convertKey(Object key, org.infinispan.commons.dataconversion.MediaType destinationFormat)
Object	convertValue(Object value, org.infinispan.commons.dataconversion.MediaType destinationFormat)
QueryRequest	decodeQueryRequest(byte[] queryRequest, org.infinispan.commons.dataconversion.MediaType requestType)
Object	encodeFilterResult(Object filterResult)
byte[]	executeQuery(String queryString, Map<String,Object> namedParametersMap, Integer offset, Integer maxResults, IndexedQueryMode queryMode, AdvancedCache cache, org.infinispan.commons.dataconversion.MediaType outputFormat)
DataConversion	getKeyDataConversion()
Class<? extends Matcher>	getMatcherClass(org.infinispan.commons.dataconversion.MediaType mediaType)
org.infinispan.query.remote.impl.BaseRemoteQueryEngine	getQueryEngine(AdvancedCache<?,?> cache)
DataConversion	getValueDataConversion()
default boolean	isQueryEnabled(AdvancedCache<byte[],byte[]> cache)

Field Detail

PROTOSTREAM_UNWRAPPED

static final org.infinispan.commons.dataconversion.MediaType PROTOSTREAM_UNWRAPPED

QUERY_REQUEST_TYPE

static final org.infinispan.commons.dataconversion.MediaType QUERY_REQUEST_TYPE

Method Detail

getMatcherClass

Class<? extends Matcher> getMatcherClass(org.infinispan.commons.dataconversion.MediaType mediaType)

Returns:

Matcher to be used during non-indexed query and filter operations.

getQueryEngine

org.infinispan.query.remote.impl.BaseRemoteQueryEngine getQueryEngine(AdvancedCache<?,?> cache)

Returns:

QueryEngine

decodeQueryRequest

QueryRequest decodeQueryRequest(byte[] queryRequest,
                                org.infinispan.commons.dataconversion.MediaType requestType)

Parameters:

queryRequest - serialized QueryRequest provided by the remote client.

Returns:

decoded QueryRequest.

encodeFilterResult

Object encodeFilterResult(Object filterResult)

Parameters:

filterResult - the FilterResult from filtering and continuous query operations.

Returns:

Encoded FilterResult to send to the remote client.

isQueryEnabled

default boolean isQueryEnabled(AdvancedCache<byte[],byte[]> cache)

convertKey

Object convertKey(Object key,
                  org.infinispan.commons.dataconversion.MediaType destinationFormat)

convertValue

Object convertValue(Object value,
                    org.infinispan.commons.dataconversion.MediaType destinationFormat)

getKeyDataConversion

DataConversion getKeyDataConversion()

getValueDataConversion

DataConversion getValueDataConversion()

executeQuery

byte[] executeQuery(String queryString,
                    Map<String,Object> namedParametersMap,
                    Integer offset,
                    Integer maxResults,
                    IndexedQueryMode queryMode,
                    AdvancedCache cache,
                    org.infinispan.commons.dataconversion.MediaType outputFormat)