Package | Description |
---|---|
org.apache.cassandra.db.streaming |
File transfer
|
org.apache.cassandra.streaming | |
org.apache.cassandra.streaming.async |
Non-blocking streaming with netty
|
org.apache.cassandra.streaming.messages |
Class and Description |
---|
StreamMessageHeader
StreamMessageHeader is appended before sending actual data to describe what it's sending.
|
Class and Description |
---|
IncomingStreamMessage |
OutgoingStreamMessage |
StreamMessage
StreamMessage is an abstract base class that every messages in streaming protocol inherit.
|
StreamMessage.Type
StreamMessage types
|
StreamMessageHeader
StreamMessageHeader is appended before sending actual data to describe what it's sending.
|
Class and Description |
---|
StreamMessage
StreamMessage is an abstract base class that every messages in streaming protocol inherit.
|
Class and Description |
---|
CompleteMessage |
IncomingStreamMessage |
KeepAliveMessage |
OutgoingStreamMessage |
PrepareAckMessage |
PrepareSynAckMessage |
PrepareSynMessage |
ReceivedMessage |
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
|
StreamMessageHeader
StreamMessageHeader is appended before sending actual data to describe what it's sending.
|
StreamMessageHeader.FileMessageHeaderSerializer |
Copyright © 2009-2020 The Apache Software Foundation