public class TxReadOnlyManyCommand<K,V,R> extends ReadOnlyManyCommand<K,V,R>
VisitableCommand.LoadType
Modifier and Type | Field and Description |
---|---|
static byte |
COMMAND_ID |
f, keyDataConversion, keys, params, valueDataConversion
Constructor and Description |
---|
TxReadOnlyManyCommand() |
TxReadOnlyManyCommand(Collection<?> keys,
List<List<Mutation<K,V,?>>> mutations,
Params params,
DataConversion keyDataConversion,
DataConversion valueDataConversion) |
TxReadOnlyManyCommand(ReadOnlyManyCommand c,
List<List<Mutation<K,V,?>>> mutations) |
Modifier and Type | Method and Description |
---|---|
byte |
getCommandId()
Used by marshallers to convert this command into an id for streaming.
|
List<List<Mutation<K,V,?>>> |
getMutations() |
void |
init(ComponentRegistry componentRegistry) |
void |
readFrom(ObjectInput input)
Reads this instance from the stream written by
ReplicableCommand.writeTo(ObjectOutput) . |
String |
toString() |
void |
writeTo(ObjectOutput output)
Writes this instance to the
ObjectOutput . |
acceptVisitor, getFunction, getKeyDataConversion, getKeys, getParams, getValueDataConversion, isReturnValueExpected, loadType, setKeys, withKeys
getTopologyId, setTopologyId
getFlagsBitSet, hasSameFlags, printFlags, setFlagsBitSet
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
canBlock, invoke, invokeAsync, isSuccessful, setOrigin
addFlag, addFlags, addFlags, getFlags, hasAllFlags, hasAnyFlag, hasFlag, setFlags
public static final byte COMMAND_ID
public TxReadOnlyManyCommand()
public TxReadOnlyManyCommand(Collection<?> keys, List<List<Mutation<K,V,?>>> mutations, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
public void init(ComponentRegistry componentRegistry)
init
in interface VisitableCommand
init
in class ReadOnlyManyCommand<K,V,R>
public byte getCommandId()
ReplicableCommand
getCommandId
in interface ReplicableCommand
getCommandId
in class ReadOnlyManyCommand<K,V,R>
public void writeTo(ObjectOutput output) throws IOException
ReplicableCommand
ObjectOutput
.writeTo
in interface ReplicableCommand
writeTo
in class ReadOnlyManyCommand<K,V,R>
output
- the stream.IOException
- if an error occurred during the I/O.public void readFrom(ObjectInput input) throws IOException, ClassNotFoundException
ReplicableCommand
ReplicableCommand.writeTo(ObjectOutput)
.readFrom
in interface ReplicableCommand
readFrom
in class ReadOnlyManyCommand<K,V,R>
input
- the stream to read.IOException
- if an error occurred during the I/O.ClassNotFoundException
- if it tries to load an undefined class.Copyright © 2021 JBoss by Red Hat. All rights reserved.