public class ClusteredQueryCommand extends BaseRpcCommand implements ReplicableCommand, CustomQueryCommand
Modifier and Type | Field and Description |
---|---|
static byte |
COMMAND_ID |
cacheName
Constructor and Description |
---|
ClusteredQueryCommand(String cacheName)
For CommandFactory only.
|
Modifier and Type | Method and Description |
---|---|
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() |
getCacheName, getOrigin, setOrigin
public static final byte COMMAND_ID
public ClusteredQueryCommand(String cacheName)
public void fetchExecutionContext(CommandInitializer ci)
fetchExecutionContext
in interface CustomQueryCommand
public static ClusteredQueryCommand createLazyIterator(org.hibernate.search.query.engine.spi.HSQuery query, Cache<?,?> cache, UUID id)
public static ClusteredQueryCommand getResultSize(org.hibernate.search.query.engine.spi.HSQuery query, Cache<?,?> cache)
public static ClusteredQueryCommand createEagerIterator(org.hibernate.search.query.engine.spi.HSQuery query, Cache<?,?> cache)
public static ClusteredQueryCommand destroyLazyQuery(Cache<?,?> cache, UUID id)
public static ClusteredQueryCommand retrieveKeyFromLazyQuery(Cache<?,?> cache, UUID id, int docIndex)
public void initialize(Cache<?,?> localInstance)
public void setCache(Cache<?,?> cache)
public Object perform(InvocationContext context) throws Throwable
perform
in interface ReplicableCommand
context
- invocation context, ignored.List
.Throwable
- in the event of problems.public QueryResponse perform(Cache<?,?> cache)
public byte getCommandId()
ReplicableCommand
getCommandId
in interface ReplicableCommand
public Object[] getParameters()
ReplicableCommand
getParameters
in interface ReplicableCommand
public void setParameters(int commandId, Object[] args)
ReplicableCommand
CommandsFactory
to create a command from raw data read off a stream.setParameters
in interface ReplicableCommand
commandId
- command id to set. This is usually unused but *could* be used in the event of a command having
multiple IDs, such as PutKeyValueCommand
.args
- object array of argspublic String toString()
toString
in class BaseRpcCommand
public boolean isReturnValueExpected()
ReplicableCommand
ResponseGenerator
may choose to simply return null to save on marshalling costs.isReturnValueExpected
in interface ReplicableCommand
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.