Package | Description |
---|---|
org.apache.cassandra.db.streaming |
File transfer
|
org.apache.cassandra.streaming | |
org.apache.cassandra.streaming.messages |
Modifier and Type | Class and Description |
---|---|
class |
CassandraOutgoingFile
used to transfer the part(or whole) of a SSTable data file
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<OutgoingStream> |
CassandraStreamManager.createOutgoingStreams(StreamSession session,
RangesAtEndpoint replicas,
java.util.UUID pendingRepair,
PreviewKind previewKind) |
Modifier and Type | Method and Description |
---|---|
static CassandraOutgoingFile |
CassandraOutgoingFile.fromStream(OutgoingStream stream) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<OutgoingStream> |
TableStreamManager.createOutgoingStreams(StreamSession session,
RangesAtEndpoint replicas,
java.util.UUID pendingRepair,
PreviewKind previewKind)
Returns a collection of
OutgoingStream 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) |
Modifier and Type | Method and Description |
---|---|
void |
StreamTransferTask.addTransferStream(OutgoingStream stream) |
OutgoingStreamMessage |
StreamHook.reportOutgoingStream(StreamSession session,
OutgoingStream stream,
OutgoingStreamMessage message) |
Modifier and Type | Method and 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
|
Modifier and Type | Field and Description |
---|---|
OutgoingStream |
OutgoingStreamMessage.stream |
Constructor and Description |
---|
OutgoingStreamMessage(TableId tableId,
StreamSession session,
OutgoingStream stream,
int sequenceNumber) |
Copyright © 2009-2022 The Apache Software Foundation