Package | Description |
---|---|
org.apache.cassandra.dht | |
org.apache.cassandra.io.sstable | |
org.apache.cassandra.repair | |
org.apache.cassandra.streaming | |
org.apache.cassandra.streaming.management |
Modifier and Type | Class and Description |
---|---|
class |
StreamStateStore
Store and update available ranges (data already received) to system keyspace.
|
Modifier and Type | Class and Description |
---|---|
class |
SSTableLoader
Cassandra SSTable bulk loader.
|
Modifier and Type | Method and Description |
---|---|
StreamResultFuture |
SSTableLoader.stream(java.util.Set<java.net.InetAddress> toIgnore,
StreamEventHandler... listeners) |
Modifier and Type | Class and Description |
---|---|
class |
LocalSyncTask
LocalSyncTask performs streaming between local(coordinator) node and remote replica.
|
class |
StreamingRepairTask
StreamingRepairTask performs data streaming between two remote replica which neither is not repair coordinator.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamResultFuture.addEventListener(StreamEventHandler listener) |
StreamPlan |
StreamPlan.listeners(StreamEventHandler handler,
StreamEventHandler... handlers) |
StreamPlan |
StreamPlan.listeners(StreamEventHandler handler,
StreamEventHandler... handlers) |
Modifier and Type | Class and Description |
---|---|
class |
StreamEventJMXNotifier |
Copyright © 2020 The Apache Software Foundation