org.infinispan.query.clustered

Class ClusteredQueryCommand

java.lang.Object

org.infinispan.commands.remote.BaseRpcCommand

org.infinispan.query.clustered.ClusteredQueryCommand

All Implemented Interfaces:

CacheRpcCommand, ReplicableCommand, CustomQueryCommand

public class ClusteredQueryCommand
extends BaseRpcCommand
implements ReplicableCommand, CustomQueryCommand

Encapsulates all rpc calls for distributed queries actions

Since:

5.1

Author:

Israel Lacerra

Field Summary

Fields

Modifier and Type	Field and Description
static byte	COMMAND_ID

Fields inherited from class org.infinispan.commands.remote.BaseRpcCommand

cacheName

Constructor Summary

Constructors

Constructor and Description
ClusteredQueryCommand(String cacheName) For CommandFactory only.

Method Summary

Modifier and Type	Method and Description
boolean	canBlock() If true, the command is processed asynchronously in a thread provided by an Infinispan thread pool.
static ClusteredQueryCommand	createEagerIterator(org.hibernate.search.query.engine.spi.HSQuery query, Cache<?,?> cache)
static ClusteredQueryCommand	createLazyIterator(org.hibernate.search.query.engine.spi.HSQuery query, Cache<?,?> cache, UUID id)
static ClusteredQueryCommand	destroyLazyQuery(Cache<?,?> cache, UUID id)
boolean	equals(Object obj)
void	fetchExecutionContext(CommandInitializer ci)
byte	getCommandId() Used by marshallers to convert this command into an id for streaming.
Object[]	getParameters() Used by marshallers to stream this command across a network
static ClusteredQueryCommand	getResultSize(org.hibernate.search.query.engine.spi.HSQuery query, Cache<?,?> cache)
int	hashCode()
void	initialize(Cache<?,?> localInstance)
boolean	isReturnValueExpected() If true, a return value will be provided when performed remotely.
QueryResponse	perform(Cache<?,?> cache)
Object	perform(InvocationContext context) Invokes a query on a (remote) cache and returns results (list of keys).
static ClusteredQueryCommand	retrieveKeyFromLazyQuery(Cache<?,?> cache, UUID id, int docIndex)
void	setCache(Cache<?,?> cache)
void	setParameters(int commandId, Object[] args) Used by the CommandsFactory to create a command from raw data read off a stream.
String	toString()

Methods inherited from class org.infinispan.commands.remote.BaseRpcCommand

getCacheName, getOrigin, setOrigin

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

COMMAND_ID

public static final byte COMMAND_ID

See Also:

Constant Field Values

Constructor Detail

ClusteredQueryCommand

public ClusteredQueryCommand(String cacheName)

For CommandFactory only. To create a ClusteredQueryCommand, use createLazyIterator(), destroyLazyQuery(), getResultSize() or retrieveKeyFromLazyQuery()

Method Detail

fetchExecutionContext

public void fetchExecutionContext(CommandInitializer ci)

Specified by:

fetchExecutionContext in interface CustomQueryCommand

createLazyIterator

public static ClusteredQueryCommand createLazyIterator(org.hibernate.search.query.engine.spi.HSQuery query,
                                                       Cache<?,?> cache,
                                                       UUID id)

getResultSize

public static ClusteredQueryCommand getResultSize(org.hibernate.search.query.engine.spi.HSQuery query,
                                                  Cache<?,?> cache)

createEagerIterator

public static ClusteredQueryCommand createEagerIterator(org.hibernate.search.query.engine.spi.HSQuery query,
                                                        Cache<?,?> cache)

destroyLazyQuery

public static ClusteredQueryCommand destroyLazyQuery(Cache<?,?> cache,
                                                     UUID id)

retrieveKeyFromLazyQuery

public static ClusteredQueryCommand retrieveKeyFromLazyQuery(Cache<?,?> cache,
                                                             UUID id,
                                                             int docIndex)

initialize

public void initialize(Cache<?,?> localInstance)

setCache

public void setCache(Cache<?,?> cache)

perform

public Object perform(InvocationContext context)
               throws Throwable

Invokes a query on a (remote) cache and returns results (list of keys).

Specified by:

perform in interface ReplicableCommand

Parameters:

context - invocation context, ignored.

Returns:

returns an List