Package org.apache.cassandra.streaming
Interface StreamHook
-
public interface StreamHook
-
-
Field Summary
Fields Modifier and Type Field Description static StreamHook
instance
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description static StreamHook
createHook()
void
reportIncomingStream(TableId tableId, IncomingStream stream, StreamSession session, int sequenceNumber)
OutgoingStreamMessage
reportOutgoingStream(StreamSession session, OutgoingStream stream, OutgoingStreamMessage message)
void
reportStreamFuture(StreamSession session, StreamResultFuture future)
-
-
-
Field Detail
-
instance
static final StreamHook instance
-
-
Method Detail
-
reportOutgoingStream
OutgoingStreamMessage reportOutgoingStream(StreamSession session, OutgoingStream stream, OutgoingStreamMessage message)
-
reportStreamFuture
void reportStreamFuture(StreamSession session, StreamResultFuture future)
-
reportIncomingStream
void reportIncomingStream(TableId tableId, IncomingStream stream, StreamSession session, int sequenceNumber)
-
createHook
static StreamHook createHook()
-
-