Package | Description |
---|---|
org.apache.cassandra.streaming | |
org.apache.cassandra.streaming.async |
Non-blocking streaming with netty
|
org.apache.cassandra.streaming.messages |
Modifier and Type | Method and Description |
---|---|
void |
StreamSession.messageReceived(StreamMessage message) |
void |
StreamingMessageSender.sendMessage(StreamMessage message) |
Modifier and Type | Method and Description |
---|---|
void |
NettyStreamingMessageSender.sendMessage(StreamMessage message) |
Modifier and Type | Interface and Description |
---|---|
static interface |
StreamMessage.Serializer<V extends StreamMessage>
StreamMessage serializer
|
Modifier and Type | Class and Description |
---|---|
class |
CompleteMessage |
class |
IncomingStreamMessage |
class |
KeepAliveMessage |
class |
OutgoingStreamMessage |
class |
PrepareAckMessage |
class |
PrepareSynAckMessage |
class |
PrepareSynMessage |
class |
ReceivedMessage |
class |
SessionFailedMessage |
class |
StreamInitMessage
StreamInitMessage is first sent from the node where
StreamSession is started,
to initiate corresponding StreamSession on the other side. |
Modifier and Type | Field and Description |
---|---|
StreamMessage.Serializer<StreamMessage> |
StreamMessage.Type.inSerializer |
StreamMessage.Serializer<StreamMessage> |
StreamMessage.Type.outSerializer |
Modifier and Type | Method and Description |
---|---|
static StreamMessage |
StreamMessage.deserialize(DataInputPlus in,
int version) |
Modifier and Type | Method and Description |
---|---|
static void |
StreamMessage.serialize(StreamMessage message,
DataOutputStreamPlus out,
int version,
StreamSession session) |
static long |
StreamMessage.serializedSize(StreamMessage message,
int version) |
Copyright © 2009-2020 The Apache Software Foundation