Package | Description |
---|---|
org.apache.cassandra.streaming | |
org.apache.cassandra.streaming.compress | |
org.apache.cassandra.streaming.messages |
Modifier and Type | Field and Description |
---|---|
protected StreamSession |
StreamReader.session |
protected StreamSession |
StreamTask.session
StreamSession that this task belongs
|
protected StreamSession |
StreamWriter.session |
Modifier and Type | Method and Description |
---|---|
StreamSession |
StreamCoordinator.getOrCreateNextSession(java.net.InetAddress peer,
java.net.InetAddress connecting) |
StreamSession |
StreamCoordinator.getOrCreateSessionById(java.net.InetAddress peer,
int id,
java.net.InetAddress connecting) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<StreamSession> |
StreamCoordinator.getAllStreamSessions() |
Modifier and Type | Method and Description |
---|---|
void |
StreamHook.reportIncomingFile(ColumnFamilyStore cfs,
SSTableMultiWriter writer,
StreamSession session,
int sequenceNumber) |
OutgoingFileMessage |
StreamHook.reportOutgoingFile(StreamSession session,
SSTableReader sstable,
OutgoingFileMessage message) |
void |
StreamHook.reportStreamFuture(StreamSession session,
StreamResultFuture future) |
Constructor and Description |
---|
SessionCompleteEvent(StreamSession session) |
StreamReader(FileMessageHeader header,
StreamSession session) |
StreamReceiveTask(StreamSession session,
java.util.UUID cfId,
int totalFiles,
long totalSize) |
StreamTask(StreamSession session,
java.util.UUID cfId) |
StreamTransferTask(StreamSession session,
java.util.UUID cfId) |
StreamWriter(SSTableReader sstable,
java.util.Collection<Pair<java.lang.Long,java.lang.Long>> sections,
StreamSession session) |
Constructor and Description |
---|
CompressedStreamReader(FileMessageHeader header,
StreamSession session) |
CompressedStreamWriter(SSTableReader sstable,
java.util.Collection<Pair<java.lang.Long,java.lang.Long>> sections,
CompressionInfo compressionInfo,
StreamSession session) |
Modifier and Type | Method and Description |
---|---|
static StreamMessage |
StreamMessage.deserialize(java.nio.channels.ReadableByteChannel in,
int version,
StreamSession session) |
V |
StreamMessage.Serializer.deserialize(java.nio.channels.ReadableByteChannel in,
int version,
StreamSession session) |
void |
OutgoingFileMessage.serialize(DataOutputStreamPlus out,
int version,
StreamSession session) |
static void |
StreamMessage.serialize(StreamMessage message,
DataOutputStreamPlus out,
int version,
StreamSession session) |
void |
StreamMessage.Serializer.serialize(V message,
DataOutputStreamPlus out,
int version,
StreamSession session) |
Copyright © 2020 The Apache Software Foundation