Package | Description |
---|---|
org.apache.cassandra.streaming | |
org.apache.cassandra.streaming.messages |
Modifier and Type | Field and Description |
---|---|
java.util.Set<StreamRequest> |
StreamEvent.SessionCompleteEvent.requests |
protected java.util.Set<StreamRequest> |
StreamSession.requests |
static IVersionedSerializer<StreamRequest> |
StreamRequest.serializer |
Modifier and Type | Method and Description |
---|---|
StreamRequest |
StreamRequest.StreamRequestSerializer.deserialize(DataInputPlus in,
int version) |
Modifier and Type | Method and Description |
---|---|
void |
StreamRequest.StreamRequestSerializer.serialize(StreamRequest request,
DataOutputPlus out,
int version) |
long |
StreamRequest.StreamRequestSerializer.serializedSize(StreamRequest request,
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.
|
Modifier and Type | Field and Description |
---|---|
java.util.Collection<StreamRequest> |
PrepareMessage.requests
Streaming requests
|
Copyright © 2018 The Apache Software Foundation