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

static byte

COMMAND_ID

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

cacheName

Constructor Summary

ClusteredQueryCommand(String cacheName)
For CommandFactory only.

Method Summary

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