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 |
CassandraIncomingFile
used to receive the part(or whole) of a SSTable data file.
|
Modifier and Type | Method and Description |
---|---|
IncomingStream |
CassandraStreamManager.prepareIncomingStream(StreamSession session,
StreamMessageHeader header) |
Modifier and Type | Method and Description |
---|---|
void |
CassandraStreamReceiver.discardStream(IncomingStream stream) |
void |
CassandraStreamReceiver.received(IncomingStream stream) |
Modifier and Type | Method and Description |
---|---|
IncomingStream |
TableStreamManager.prepareIncomingStream(StreamSession session,
StreamMessageHeader header)
Creates an
IncomingStream for the given header |
Modifier and Type | Method and Description |
---|---|
void |
StreamReceiver.discardStream(IncomingStream stream)
This is called when we've received stream data we can't add to the received set for some reason,
usually when we've received data for a session which has been closed.
|
void |
StreamReceiveTask.received(IncomingStream stream)
Process received stream.
|
void |
StreamReceiver.received(IncomingStream stream)
Called after we've finished receiving stream data.
|
void |
StreamHook.reportIncomingStream(TableId tableId,
IncomingStream stream,
StreamSession session,
int sequenceNumber) |
Modifier and Type | Field and Description |
---|---|
IncomingStream |
IncomingStreamMessage.stream |
Constructor and Description |
---|
IncomingStreamMessage(IncomingStream stream,
StreamMessageHeader header) |
Copyright © 2009-2022 The Apache Software Foundation