Package | Description |
---|---|
org.apache.cassandra.streaming | |
org.apache.cassandra.streaming.management | |
org.apache.cassandra.streaming.messages |
Modifier and Type | Field and Description |
---|---|
java.util.Collection<StreamSummary> |
SessionInfo.receivingSummaries
Immutable collection of receiving summaries
|
java.util.Collection<StreamSummary> |
SessionInfo.sendingSummaries
Immutable collection of sending summaries
|
static IVersionedSerializer<StreamSummary> |
StreamSummary.serializer |
Modifier and Type | Method and Description |
---|---|
StreamSummary |
StreamSummary.StreamSummarySerializer.deserialize(DataInputPlus in,
int version) |
StreamSummary |
StreamTask.getSummary() |
Modifier and Type | Method and Description |
---|---|
void |
StreamSummary.StreamSummarySerializer.serialize(StreamSummary summary,
DataOutputPlus out,
int version) |
long |
StreamSummary.StreamSummarySerializer.serializedSize(StreamSummary summary,
int version) |
Modifier and Type | Method and Description |
---|---|
void |
StreamSession.prepare(java.util.Collection<StreamRequest> requests,
java.util.Collection<StreamSummary> summaries)
Prepare this session for sending/receiving files.
|
Constructor and Description |
---|
SessionInfo(java.net.InetAddress peer,
int sessionIndex,
java.net.InetAddress connecting,
java.util.Collection<StreamSummary> receivingSummaries,
java.util.Collection<StreamSummary> sendingSummaries,
StreamSession.State state) |
SessionInfo(java.net.InetAddress peer,
int sessionIndex,
java.net.InetAddress connecting,
java.util.Collection<StreamSummary> receivingSummaries,
java.util.Collection<StreamSummary> sendingSummaries,
StreamSession.State state) |
Modifier and Type | Method and Description |
---|---|
static StreamSummary |
StreamSummaryCompositeData.fromCompositeData(javax.management.openmbean.CompositeData cd) |
Modifier and Type | Method and Description |
---|---|
static javax.management.openmbean.CompositeData |
StreamSummaryCompositeData.toCompositeData(StreamSummary streamSummary) |
Modifier and Type | Field and Description |
---|---|
java.util.Collection<StreamSummary> |
PrepareMessage.summaries
Summaries of streaming out
|
Copyright © 2020 The Apache Software Foundation