Package org.apache.cassandra.streaming.messages

Interface StreamMessage.Serializer<V extends StreamMessage>

Enclosing class:

StreamMessage

public static interface StreamMessage.Serializer<V extends StreamMessage>

StreamMessage serializer

Method Summary

Modifier and Type	Method	Description
V	deserialize(DataInputPlus in, int version)
void	serialize(V message, StreamingDataOutputPlus out, int version, StreamSession session)
long	serializedSize(V message, int version)

Method Details

deserialize

V deserialize(DataInputPlus in,
 int version)
       throws IOException

Throws:

IOException

serialize

void serialize(V message,
 StreamingDataOutputPlus out,
 int version,
 StreamSession session)
        throws IOException

Throws:

IOException

serializedSize

long serializedSize(V message,
 int version)
             throws IOException

Throws:

IOException