Package | Description |
---|---|
org.apache.cassandra.exceptions | |
org.apache.cassandra.repair | |
org.apache.cassandra.repair.messages |
Modifier and Type | Field and Description |
---|---|
RepairJobDesc |
RepairException.desc |
Constructor and Description |
---|
RepairException(RepairJobDesc desc,
java.lang.String message) |
RepairException(RepairJobDesc desc,
java.lang.String message,
java.lang.Throwable cause) |
Modifier and Type | Field and Description |
---|---|
RepairJobDesc |
RepairResult.desc |
protected RepairJobDesc |
SyncTask.desc |
RepairJobDesc |
Validator.desc |
Modifier and Type | Field and Description |
---|---|
static IVersionedSerializer<RepairJobDesc> |
RepairJobDesc.serializer |
Modifier and Type | Method and Description |
---|---|
void |
RepairSession.syncComplete(RepairJobDesc desc,
NodePair nodes,
boolean success)
Notify this session that sync completed/failed with given
NodePair . |
void |
RepairSession.validationComplete(RepairJobDesc desc,
java.net.InetAddress endpoint,
MerkleTrees trees)
Receive merkle tree response or failed response from
endpoint for current repair job. |
Modifier and Type | Method and Description |
---|---|
void |
RepairSession.waitForSync(Pair<RepairJobDesc,NodePair> key,
RemoteSyncTask task) |
void |
RepairSession.waitForValidation(Pair<RepairJobDesc,java.net.InetAddress> key,
ValidationTask task) |
Constructor and Description |
---|
LocalSyncTask(RepairJobDesc desc,
TreeResponse r1,
TreeResponse r2,
long repairedAt,
boolean pullRepair) |
RemoteSyncTask(RepairJobDesc desc,
TreeResponse r1,
TreeResponse r2) |
RepairResult(RepairJobDesc desc,
java.util.List<SyncStat> stats) |
SnapshotTask(RepairJobDesc desc,
java.net.InetAddress endpoint) |
StreamingRepairTask(RepairJobDesc desc,
SyncRequest request,
long repairedAt) |
SyncTask(RepairJobDesc desc,
TreeResponse r1,
TreeResponse r2) |
ValidationTask(RepairJobDesc desc,
java.net.InetAddress endpoint,
int gcBefore) |
Validator(RepairJobDesc desc,
java.net.InetAddress initiator,
int gcBefore) |
Validator(RepairJobDesc desc,
java.net.InetAddress initiator,
int gcBefore,
boolean evenTreeDistribution) |
Modifier and Type | Field and Description |
---|---|
RepairJobDesc |
RepairMessage.desc |
Constructor and Description |
---|
RepairMessage(RepairMessage.Type messageType,
RepairJobDesc desc) |
SnapshotMessage(RepairJobDesc desc) |
SyncComplete(RepairJobDesc desc,
java.net.InetAddress endpoint1,
java.net.InetAddress endpoint2,
boolean success) |
SyncComplete(RepairJobDesc desc,
NodePair nodes,
boolean success) |
SyncRequest(RepairJobDesc desc,
java.net.InetAddress initiator,
java.net.InetAddress src,
java.net.InetAddress dst,
java.util.Collection<Range<Token>> ranges) |
ValidationComplete(RepairJobDesc desc) |
ValidationComplete(RepairJobDesc desc,
MerkleTrees trees) |
ValidationRequest(RepairJobDesc desc,
int gcBefore) |
Copyright © 2018 The Apache Software Foundation