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, valueDataConversion
key, 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, performOnLostData
equals, getFlagsBitSet, getKey, getSegment, getTopologyId, hashCode, isReturnValueExpected, printFlags, setFlagsBitSet, setKey, setTopologyId
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
addFlag, addFlags, addFlags, getFlags, hasAllFlags, hasAnyFlag, hasFlag, setFlags
canBlock, invoke, invokeAsync, isSuccessful, setOrigin
extractSegment
public 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()
ReplicableCommand
getCommandId
in interface ReplicableCommand
getCommandId
in class ReadOnlyKeyCommand<K,V,R>
public void writeTo(ObjectOutput output) throws IOException
ReplicableCommand
ObjectOutput
.writeTo
in interface ReplicableCommand
writeTo
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
ReplicableCommand
ReplicableCommand.writeTo(ObjectOutput)
.readFrom
in interface ReplicableCommand
readFrom
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 VisitableCommand
init
in class ReadOnlyKeyCommand<K,V,R>
Copyright © 2021 JBoss by Red Hat. All rights reserved.