Class AggregatorMessage
- java.lang.Object
-
- com.alibaba.graphscope.graph.comm.requests.ByteArrayMessage
-
- com.alibaba.graphscope.graph.comm.requests.AggregatorMessage
-
- All Implemented Interfaces:
NettyMessage
,org.apache.hadoop.io.Writable
public class AggregatorMessage extends ByteArrayMessage
-
-
Constructor Summary
Constructors Constructor Description AggregatorMessage()
AggregatorMessage(String aggregatorId, String value, byte[] valueBytes)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getAggregatorId()
NettyMessageType
getMessageType()
int
getSerializedSize()
String
getValue()
void
readFields(DataInput input)
String
toString()
void
write(DataOutput output)
-
Methods inherited from class com.alibaba.graphscope.graph.comm.requests.ByteArrayMessage
getData, getDataInput, setData
-
-
-
-
Method Detail
-
getValue
public String getValue()
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSize
in interfaceNettyMessage
- Overrides:
getSerializedSize
in classByteArrayMessage
-
getAggregatorId
public String getAggregatorId()
-
getMessageType
public NettyMessageType getMessageType()
- Specified by:
getMessageType
in interfaceNettyMessage
- Overrides:
getMessageType
in classByteArrayMessage
-
readFields
public void readFields(DataInput input) throws IOException
- Specified by:
readFields
in interfaceorg.apache.hadoop.io.Writable
- Overrides:
readFields
in classByteArrayMessage
- Throws:
IOException
-
write
public void write(DataOutput output) throws IOException
- Specified by:
write
in interfaceorg.apache.hadoop.io.Writable
- Overrides:
write
in classByteArrayMessage
- Throws:
IOException
-
-