Uses of Class
org.apache.cassandra.streaming.messages.OutgoingStreamMessage
-
Packages that use OutgoingStreamMessage Package Description org.apache.cassandra.streaming org.apache.cassandra.streaming.messages -
-
Uses of OutgoingStreamMessage in org.apache.cassandra.streaming
Fields in org.apache.cassandra.streaming with type parameters of type OutgoingStreamMessage Modifier and Type Field Description protected java.util.Map<java.lang.Integer,OutgoingStreamMessage>
StreamTransferTask. streams
Methods in org.apache.cassandra.streaming that return OutgoingStreamMessage Modifier and Type Method Description OutgoingStreamMessage
StreamTransferTask. createMessageForRetry(int sequenceNumber)
OutgoingStreamMessage
StreamHook. reportOutgoingStream(StreamSession session, OutgoingStream stream, OutgoingStreamMessage message)
Methods in org.apache.cassandra.streaming that return types with arguments of type OutgoingStreamMessage Modifier and Type Method Description java.util.Collection<OutgoingStreamMessage>
StreamTransferTask. getFileMessages()
Methods in org.apache.cassandra.streaming with parameters of type OutgoingStreamMessage Modifier and Type Method Description OutgoingStreamMessage
StreamHook. reportOutgoingStream(StreamSession session, OutgoingStream stream, OutgoingStreamMessage message)
void
StreamSession. streamSent(OutgoingStreamMessage message)
Call back after sending StreamMessageHeader. -
Uses of OutgoingStreamMessage in org.apache.cassandra.streaming.messages
Fields in org.apache.cassandra.streaming.messages with type parameters of type OutgoingStreamMessage Modifier and Type Field Description static StreamMessage.Serializer<OutgoingStreamMessage>
OutgoingStreamMessage. serializer
-