Package | Description |
---|---|
org.apache.cassandra.dht | |
org.apache.cassandra.io.sstable | |
org.apache.cassandra.streaming |
Modifier and Type | Method and Description |
---|---|
StreamResultFuture |
RangeStreamer.fetchAsync() |
Modifier and Type | Method and Description |
---|---|
StreamResultFuture |
SSTableLoader.stream() |
StreamResultFuture |
SSTableLoader.stream(java.util.Set<InetAddressAndPort> toIgnore,
StreamEventHandler... listeners) |
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) |
StreamResultFuture |
StreamPlan.execute()
Execute this
StreamPlan asynchronously. |
StreamResultFuture |
StreamManager.getReceivingStream(java.util.UUID planId) |
StreamResultFuture |
StreamManager.registerFollower(StreamResultFuture result) |
Modifier and Type | Method and Description |
---|---|
void |
StreamCoordinator.connect(StreamResultFuture future) |
void |
StreamSession.init(StreamResultFuture streamResult)
Bind this session to report to specific
StreamResultFuture and
perform pre-streaming initialization. |
StreamResultFuture |
StreamManager.registerFollower(StreamResultFuture result) |
void |
StreamManager.registerInitiator(StreamResultFuture result) |
void |
StreamHook.reportStreamFuture(StreamSession session,
StreamResultFuture future) |
Copyright © 2009-2020 The Apache Software Foundation