Class StreamInitMessage
- java.lang.Object
-
- org.apache.cassandra.streaming.messages.StreamMessage
-
- org.apache.cassandra.streaming.messages.StreamInitMessage
-
public class StreamInitMessage extends StreamMessage
StreamInitMessage is first sent from the node whereStreamSession
is started, to initiate correspondingStreamSession
on the other side.
-
-
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 InetAddressAndPort
from
java.util.UUID
pendingRepair
java.util.UUID
planId
PreviewKind
previewKind
static StreamMessage.Serializer<StreamInitMessage>
serializer
int
sessionIndex
StreamOperation
streamOperation
-
Fields inherited from class org.apache.cassandra.streaming.messages.StreamMessage
type
-
-
Constructor Summary
Constructors Constructor Description StreamInitMessage(InetAddressAndPort from, int sessionIndex, java.util.UUID planId, StreamOperation streamOperation, java.util.UUID pendingRepair, PreviewKind previewKind)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StreamSession
getOrCreateSession(io.netty.channel.Channel channel)
Get or create aStreamSession
based on this stream message data: not all stream messages support this, so the default implementation just throws an exception.java.lang.String
toString()
-
Methods inherited from class org.apache.cassandra.streaming.messages.StreamMessage
deserialize, getPriority, serialize, serializedSize
-
-
-
-
Field Detail
-
serializer
public static StreamMessage.Serializer<StreamInitMessage> serializer
-
from
public final InetAddressAndPort from
-
sessionIndex
public final int sessionIndex
-
planId
public final java.util.UUID planId
-
streamOperation
public final StreamOperation streamOperation
-
pendingRepair
public final java.util.UUID pendingRepair
-
previewKind
public final PreviewKind previewKind
-
-
Constructor Detail
-
StreamInitMessage
public StreamInitMessage(InetAddressAndPort from, int sessionIndex, java.util.UUID planId, StreamOperation streamOperation, java.util.UUID pendingRepair, PreviewKind previewKind)
-
-
Method Detail
-
getOrCreateSession
public StreamSession getOrCreateSession(io.netty.channel.Channel channel)
Description copied from class:StreamMessage
Get or create aStreamSession
based on this stream message data: not all stream messages support this, so the default implementation just throws an exception.- Overrides:
getOrCreateSession
in classStreamMessage
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-