Package | Description |
---|---|
org.apache.cassandra.gms | |
org.apache.cassandra.locator | |
org.apache.cassandra.repair | |
org.apache.cassandra.service | |
org.apache.cassandra.streaming |
Modifier and Type | Field and Description |
---|---|
static IVersionedSerializer<VersionedValue> |
VersionedValue.serializer |
Modifier and Type | Method and Description |
---|---|
VersionedValue |
VersionedValue.VersionedValueFactory.bootReplacing(java.net.InetAddress oldNode) |
VersionedValue |
VersionedValue.VersionedValueFactory.bootstrapping(java.util.Collection<Token> tokens) |
VersionedValue |
VersionedValue.VersionedValueFactory.cloneWithHigherVersion(VersionedValue value) |
VersionedValue |
VersionedValue.VersionedValueFactory.datacenter(java.lang.String dcId) |
VersionedValue |
EndpointState.getApplicationState(ApplicationState key) |
VersionedValue |
VersionedValue.VersionedValueFactory.hibernate(boolean value) |
VersionedValue |
VersionedValue.VersionedValueFactory.hostId(java.util.UUID hostId) |
VersionedValue |
VersionedValue.VersionedValueFactory.internalIP(java.lang.String private_ip) |
VersionedValue |
VersionedValue.VersionedValueFactory.leaving(java.util.Collection<Token> tokens) |
VersionedValue |
VersionedValue.VersionedValueFactory.left(java.util.Collection<Token> tokens,
long expireTime) |
VersionedValue |
VersionedValue.VersionedValueFactory.load(double load) |
VersionedValue |
VersionedValue.VersionedValueFactory.moving(Token token) |
VersionedValue |
VersionedValue.VersionedValueFactory.networkVersion() |
VersionedValue |
VersionedValue.VersionedValueFactory.normal(java.util.Collection<Token> tokens) |
VersionedValue |
VersionedValue.VersionedValueFactory.rack(java.lang.String rackId) |
VersionedValue |
VersionedValue.VersionedValueFactory.releaseVersion() |
VersionedValue |
VersionedValue.VersionedValueFactory.removalCoordinator(java.util.UUID hostId) |
VersionedValue |
VersionedValue.VersionedValueFactory.removedNonlocal(java.util.UUID hostId,
long expireTime) |
VersionedValue |
VersionedValue.VersionedValueFactory.removingNonlocal(java.util.UUID hostId) |
VersionedValue |
VersionedValue.VersionedValueFactory.rpcaddress(java.net.InetAddress endpoint) |
VersionedValue |
VersionedValue.VersionedValueFactory.rpcReady(boolean value) |
VersionedValue |
VersionedValue.VersionedValueFactory.schema(java.util.UUID newVersion) |
VersionedValue |
VersionedValue.VersionedValueFactory.severity(double value) |
VersionedValue |
VersionedValue.VersionedValueFactory.shutdown(boolean value) |
VersionedValue |
VersionedValue.VersionedValueFactory.tokens(java.util.Collection<Token> tokens) |
Modifier and Type | Method and Description |
---|---|
java.util.Set<java.util.Map.Entry<ApplicationState,VersionedValue>> |
EndpointState.states() |
Modifier and Type | Method and Description |
---|---|
void |
EndpointState.addApplicationState(ApplicationState key,
VersionedValue value) |
void |
Gossiper.addLocalApplicationState(ApplicationState applicationState,
VersionedValue value) |
void |
IEndpointStateChangeSubscriber.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
VersionedValue |
VersionedValue.VersionedValueFactory.cloneWithHigherVersion(VersionedValue value) |
int |
VersionedValue.compareTo(VersionedValue value) |
void |
Gossiper.injectApplicationState(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
void |
IEndpointStateChangeSubscriber.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
Modifier and Type | Method and Description |
---|---|
void |
EndpointState.addApplicationStates(java.util.Map<ApplicationState,VersionedValue> values) |
void |
EndpointState.addApplicationStates(java.util.Set<java.util.Map.Entry<ApplicationState,VersionedValue>> values) |
void |
Gossiper.addLocalApplicationStates(java.util.List<Pair<ApplicationState,VersionedValue>> states) |
void |
Gossiper.start(int generationNbr,
java.util.Map<ApplicationState,VersionedValue> preloadLocalStates)
Start the gossiper with the generation number, preloading the map of application states before starting
|
Modifier and Type | Method and Description |
---|---|
void |
ReconnectableSnitchHelper.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
ReconnectableSnitchHelper.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
Modifier and Type | Method and Description |
---|---|
void |
AnticompactionTask.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
RepairSession.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
AnticompactionTask.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
void |
RepairSession.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveRepairService.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
LoadBroadcaster.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
StorageService.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
ActiveRepairService.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
void |
LoadBroadcaster.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
void |
StorageService.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
Modifier and Type | Method and Description |
---|---|
void |
StreamSession.beforeChange(java.net.InetAddress endpoint,
EndpointState currentState,
ApplicationState newStateKey,
VersionedValue newValue) |
void |
StreamSession.onChange(java.net.InetAddress endpoint,
ApplicationState state,
VersionedValue value) |
Copyright © 2018 The Apache Software Foundation