Package | Description |
---|---|
org.apache.cassandra.streaming | |
org.apache.cassandra.streaming.compress | |
org.apache.cassandra.streaming.messages |
Class and Description |
---|
FileMessageHeader
StreamingFileHeader is appended before sending actual data to describe what it's sending.
|
IncomingFileMessage
IncomingFileMessage is used to receive the part(or whole) of a SSTable data file.
|
OutgoingFileMessage
OutgoingFileMessage is used to transfer the part(or whole) of a SSTable data file.
|
StreamMessage
StreamMessage is an abstract base class that every messages in streaming protocol inherit.
|
Class and Description |
---|
FileMessageHeader
StreamingFileHeader is appended before sending actual data to describe what it's sending.
|
Class and Description |
---|
CompleteMessage |
FileMessageHeader
StreamingFileHeader is appended before sending actual data to describe what it's sending.
|
IncomingFileMessage
IncomingFileMessage is used to receive the part(or whole) of a SSTable data file.
|
KeepAliveMessage |
OutgoingFileMessage
OutgoingFileMessage is used to transfer the part(or whole) of a SSTable data file.
|
PrepareMessage |
ReceivedMessage |
RetryMessage
Deprecated.
retry support removed on CASSANDRA-10992
|
SessionFailedMessage |
StreamInitMessage
StreamInitMessage is first sent from the node where
StreamSession is started,
to initiate corresponding StreamSession on the other side. |
StreamMessage
StreamMessage is an abstract base class that every messages in streaming protocol inherit.
|
StreamMessage.Serializer
StreamMessage serializer
|
StreamMessage.Type
StreamMessage types
|
Copyright © 2020 The Apache Software Foundation