Uses of Interface
org.apache.cassandra.streaming.OutgoingStream
-
Packages that use OutgoingStream Package Description org.apache.cassandra.db.streaming File transferorg.apache.cassandra.streaming org.apache.cassandra.streaming.messages -
-
Uses of OutgoingStream in org.apache.cassandra.db.streaming
Classes in org.apache.cassandra.db.streaming that implement OutgoingStream Modifier and Type Class Description class
CassandraOutgoingFile
used to transfer the part(or whole) of a SSTable data fileMethods in org.apache.cassandra.db.streaming that return types with arguments of type OutgoingStream Modifier and Type Method Description java.util.Collection<OutgoingStream>
CassandraStreamManager. createOutgoingStreams(StreamSession session, RangesAtEndpoint replicas, java.util.UUID pendingRepair, PreviewKind previewKind)
Methods in org.apache.cassandra.db.streaming with parameters of type OutgoingStream Modifier and Type Method Description static CassandraOutgoingFile
CassandraOutgoingFile. fromStream(OutgoingStream stream)
-
Uses of OutgoingStream in org.apache.cassandra.streaming
Methods in org.apache.cassandra.streaming that return types with arguments of type OutgoingStream Modifier and Type Method Description java.util.Collection<OutgoingStream>
TableStreamManager. createOutgoingStreams(StreamSession session, RangesAtEndpoint replicas, java.util.UUID pendingRepair, PreviewKind previewKind)
Returns a collection ofOutgoingStream
s that contains the data selected by the given replicas, pendingRepair, and preview.java.util.List<OutgoingStream>
StreamSession. getOutgoingStreamsForRanges(RangesAtEndpoint replicas, java.util.Collection<ColumnFamilyStore> stores, java.util.UUID pendingRepair, PreviewKind previewKind)
Methods in org.apache.cassandra.streaming with parameters of type OutgoingStream Modifier and Type Method Description void
StreamTransferTask. addTransferStream(OutgoingStream stream)
OutgoingStreamMessage
StreamHook. reportOutgoingStream(StreamSession session, OutgoingStream stream, OutgoingStreamMessage message)
Method parameters in org.apache.cassandra.streaming with type arguments of type OutgoingStream Modifier and Type Method Description void
StreamCoordinator. transferStreams(InetAddressAndPort to, java.util.Collection<OutgoingStream> streams)
StreamPlan
StreamPlan. transferStreams(InetAddressAndPort to, java.util.Collection<OutgoingStream> streams)
Add transfer task to send given streams -
Uses of OutgoingStream in org.apache.cassandra.streaming.messages
Fields in org.apache.cassandra.streaming.messages declared as OutgoingStream Modifier and Type Field Description OutgoingStream
OutgoingStreamMessage. stream
Constructors in org.apache.cassandra.streaming.messages with parameters of type OutgoingStream Constructor Description OutgoingStreamMessage(TableId tableId, StreamSession session, OutgoingStream stream, int sequenceNumber)
-