Package org.apache.cassandra.streaming.messages

Class OutgoingStreamMessage

java.lang.Object

org.apache.cassandra.streaming.messages.StreamMessage

org.apache.cassandra.streaming.messages.OutgoingStreamMessage

public class OutgoingStreamMessage
extends StreamMessage

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.streaming.messages.StreamMessage

StreamMessage.Serializer<V extends StreamMessage>, StreamMessage.Type

Field Summary

Fields

Modifier and Type	Field	Description
final StreamMessageHeader	header
static StreamMessage.Serializer<OutgoingStreamMessage>	serializer
final OutgoingStream	stream

Fields inherited from class org.apache.cassandra.streaming.messages.StreamMessage

type

Constructor Summary

Constructors

Constructor	Description
OutgoingStreamMessage(TableId tableId, StreamSession session, OutgoingStream stream, int sequenceNumber)

Method Summary

Modifier and Type	Method	Description
void	complete()
void	finishTransfer()
String	getName()
void	serialize(StreamingDataOutputPlus out, int version, StreamSession session)
void	startTransfer()
String	toString()

Methods inherited from class org.apache.cassandra.streaming.messages.StreamMessage

deserialize, getOrCreateAndAttachInboundSession, getPriority, serialize, serializedSize

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

serializer

public static StreamMessage.Serializer<OutgoingStreamMessage> serializer

header

public final StreamMessageHeader header

stream

public final OutgoingStream stream

Constructor Details

OutgoingStreamMessage

public OutgoingStreamMessage(TableId tableId,
 StreamSession session,
 OutgoingStream stream,
 int sequenceNumber)

Method Details

serialize

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

Throws:

IOException

finishTransfer

public void finishTransfer()

startTransfer

public void startTransfer()

complete

public void complete()

toString

public String toString()

Overrides:

toString in class Object

getName

public String getName()