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 StringgetAggregatorId()NettyMessageTypegetMessageType()intgetSerializedSize()StringgetValue()voidreadFields(DataInput input)StringtoString()voidwrite(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:
getSerializedSizein interfaceNettyMessage- Overrides:
getSerializedSizein classByteArrayMessage
-
getAggregatorId
public String getAggregatorId()
-
getMessageType
public NettyMessageType getMessageType()
- Specified by:
getMessageTypein interfaceNettyMessage- Overrides:
getMessageTypein classByteArrayMessage
-
readFields
public void readFields(DataInput input) throws IOException
- Specified by:
readFieldsin interfaceorg.apache.hadoop.io.Writable- Overrides:
readFieldsin classByteArrayMessage- Throws:
IOException
-
write
public void write(DataOutput output) throws IOException
- Specified by:
writein interfaceorg.apache.hadoop.io.Writable- Overrides:
writein classByteArrayMessage- Throws:
IOException
-
-