Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.db.streaming |
File transfer
|
org.apache.cassandra.dht | |
org.apache.cassandra.streaming | |
org.apache.cassandra.streaming.messages |
Modifier and Type | Method and Description |
---|---|
static void |
SystemKeyspace.updateTransferredRanges(StreamOperation streamOperation,
InetAddressAndPort peer,
java.lang.String keyspace,
java.util.Collection<Range<Token>> streamedRanges) |
Constructor and Description |
---|
CassandraOutgoingFile(StreamOperation operation,
Ref<SSTableReader> ref,
java.util.List<SSTableReader.PartitionPositionBounds> sections,
java.util.List<Range<Token>> normalizedRanges,
long estimatedKeys) |
Constructor and Description |
---|
RangeStreamer(TokenMetadata metadata,
java.util.Collection<Token> tokens,
InetAddressAndPort address,
StreamOperation streamOperation,
boolean useStrictConsistency,
IEndpointSnitch snitch,
StreamStateStore stateStore,
boolean connectSequentially,
int connectionsPerHost) |
Modifier and Type | Field and Description |
---|---|
StreamOperation |
StreamEvent.SessionCompleteEvent.streamOperation |
StreamOperation |
StreamResultFuture.streamOperation |
StreamOperation |
StreamState.streamOperation |
Modifier and Type | Method and Description |
---|---|
static StreamOperation |
StreamOperation.fromString(java.lang.String text) |
StreamOperation |
StreamSession.getStreamOperation() |
StreamOperation |
StreamSession.streamOperation() |
static StreamOperation |
StreamOperation.valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static StreamOperation[] |
StreamOperation.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static StreamResultFuture |
StreamResultFuture.createFollower(int sessionIndex,
java.util.UUID planId,
StreamOperation streamOperation,
InetAddressAndPort from,
io.netty.channel.Channel channel,
java.util.UUID pendingRepair,
PreviewKind previewKind) |
static StreamResultFuture |
StreamResultFuture.createInitiator(java.util.UUID planId,
StreamOperation streamOperation,
java.util.Collection<StreamEventHandler> listeners,
StreamCoordinator coordinator) |
Constructor and Description |
---|
StreamCoordinator(StreamOperation streamOperation,
int connectionsPerHost,
StreamConnectionFactory factory,
boolean follower,
boolean connectSequentially,
java.util.UUID pendingRepair,
PreviewKind previewKind) |
StreamPlan(StreamOperation streamOperation)
Start building stream plan.
|
StreamPlan(StreamOperation streamOperation,
boolean connectSequentially) |
StreamPlan(StreamOperation streamOperation,
int connectionsPerHost,
boolean connectSequentially,
java.util.UUID pendingRepair,
PreviewKind previewKind) |
StreamSession(StreamOperation streamOperation,
InetAddressAndPort peer,
StreamConnectionFactory factory,
boolean isFollower,
int index,
java.util.UUID pendingRepair,
PreviewKind previewKind)
Create new streaming session with the peer.
|
StreamState(java.util.UUID planId,
StreamOperation streamOperation,
java.util.Set<SessionInfo> sessions) |
Modifier and Type | Field and Description |
---|---|
StreamOperation |
StreamInitMessage.streamOperation |
Constructor and Description |
---|
StreamInitMessage(InetAddressAndPort from,
int sessionIndex,
java.util.UUID planId,
StreamOperation streamOperation,
java.util.UUID pendingRepair,
PreviewKind previewKind) |
Copyright © 2009-2020 The Apache Software Foundation