public class TxReadOnlyKeyCommand<K,V,R> extends ReadOnlyKeyCommand<K,V,R>
VisitableCommand.LoadType| Modifier and Type | Field and Description |
|---|---|
static byte |
COMMAND_ID |
f, keyDataConversion, params, valueDataConversionkey, segment| Constructor and Description |
|---|
TxReadOnlyKeyCommand() |
TxReadOnlyKeyCommand(Object key,
Function<EntryView.ReadEntryView<K,V>,R> f,
List<Mutation<K,V,?>> mutations,
int segment,
Params params,
DataConversion keyDataConversion,
DataConversion valueDataConversion) |
| Modifier and Type | Method and Description |
|---|---|
byte |
getCommandId()
Used by marshallers to convert this command into an id for streaming.
|
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, getParams, getValueDataConversion, loadType, performOnLostDataequals, getFlagsBitSet, getKey, getSegment, getTopologyId, hashCode, isReturnValueExpected, printFlags, setFlagsBitSet, setKey, setTopologyIdclone, finalize, getClass, notify, notifyAll, wait, wait, waitaddFlag, addFlags, addFlags, getFlags, hasAllFlags, hasAnyFlag, hasFlag, setFlagscanBlock, invoke, invokeAsync, isSuccessful, setOriginextractSegmentpublic static final byte COMMAND_ID
public TxReadOnlyKeyCommand()
public TxReadOnlyKeyCommand(Object key, Function<EntryView.ReadEntryView<K,V>,R> f, List<Mutation<K,V,?>> mutations, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
public byte getCommandId()
ReplicableCommandgetCommandId in interface ReplicableCommandgetCommandId in class ReadOnlyKeyCommand<K,V,R>public void writeTo(ObjectOutput output) throws IOException
ReplicableCommandObjectOutput.writeTo in interface ReplicableCommandwriteTo in class ReadOnlyKeyCommand<K,V,R>output - the stream.IOException - if an error occurred during the I/O.public void readFrom(ObjectInput input) throws IOException, ClassNotFoundException
ReplicableCommandReplicableCommand.writeTo(ObjectOutput).readFrom in interface ReplicableCommandreadFrom in class ReadOnlyKeyCommand<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.public void init(ComponentRegistry componentRegistry)
init in interface VisitableCommandinit in class ReadOnlyKeyCommand<K,V,R>Copyright © 2022 JBoss by Red Hat. All rights reserved.