Package org.infinispan.query.indexmanager

Class IndexUpdateStreamCommand

java.lang.Object

org.infinispan.commands.remote.BaseRpcCommand

org.infinispan.query.indexmanager.AbstractUpdateCommand

org.infinispan.query.indexmanager.IndexUpdateStreamCommand

All Implemented Interfaces:

org.infinispan.commands.remote.CacheRpcCommand, ReplicableCommand, CustomQueryCommand

public class IndexUpdateStreamCommand
extends AbstractUpdateCommand

Execute a stream operation

Since:

7.0

Author:

gustavonalle

Field Summary

Fields

Modifier and Type	Field	Description
static byte	COMMAND_ID

Fields inherited from class org.infinispan.query.indexmanager.AbstractUpdateCommand

indexName, queryInterceptor, searchFactory, serializedModel

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

cacheName

Constructor Summary

Constructors

Constructor	Description
IndexUpdateStreamCommand(ByteString cacheName)

Method Summary

Modifier and Type	Method	Description
byte	getCommandId()	Used by marshallers to convert this command into an id for streaming.
CompletableFuture<Object>	invokeAsync()	Invoke the command asynchronously.

Methods inherited from class org.infinispan.query.indexmanager.AbstractUpdateCommand

canBlock, getIndexName, isReturnValueExpected, readFrom, setCacheManager, setIndexName, setSerializedWorkList, writeTo

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

getCacheName, getOrigin, setOrigin, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commands.remote.CacheRpcCommand

getCacheName, getOrigin, setOrigin

Methods inherited from interface org.infinispan.commands.ReplicableCommand

invoke, isSuccessful, perform

Field Detail

COMMAND_ID

public static final byte COMMAND_ID

See Also:

Constant Field Values

Constructor Detail

IndexUpdateStreamCommand

public IndexUpdateStreamCommand(ByteString cacheName)

Method Detail

invokeAsync

public CompletableFuture<Object> invokeAsync()

Description copied from interface: ReplicableCommand

Invoke the command asynchronously.

This method replaces ReplicableCommand.perform(InvocationContext) for remote execution. The default implementation and ReplicableCommand.perform(InvocationContext) will be removed in future versions.

Specified by:

invokeAsync in interface ReplicableCommand

Specified by:

invokeAsync in class AbstractUpdateCommand

getCommandId

public byte getCommandId()

Description copied from interface: ReplicableCommand

Used by marshallers to convert this command into an id for streaming.

Specified by:

getCommandId in interface ReplicableCommand

Specified by:

getCommandId in class AbstractUpdateCommand

Returns:

the method id of this command. This is compatible with pre-2.2.0 MethodCall ids.