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,
PreviewKind previewKind,
java.lang.String message) |
RepairException(RepairJobDesc desc,
java.lang.String message) |
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,
SyncNodePair nodes,
boolean success,
java.util.List<SessionSummary> summaries)
Notify this session that sync completed/failed with given
SyncNodePair . |
void |
RepairSession.validationComplete(RepairJobDesc desc,
InetAddressAndPort endpoint,
MerkleTrees trees)
Receive merkle tree response or failed response from
endpoint for current repair job. |
Modifier and Type | Method and Description |
---|---|
void |
RepairSession.trackSyncCompletion(Pair<RepairJobDesc,SyncNodePair> key,
CompletableRemoteSyncTask task) |
void |
RepairSession.trackValidationCompletion(Pair<RepairJobDesc,InetAddressAndPort> key,
ValidationTask task) |
Constructor and Description |
---|
AsymmetricRemoteSyncTask(RepairJobDesc desc,
InetAddressAndPort to,
InetAddressAndPort from,
java.util.List<Range<Token>> differences,
PreviewKind previewKind) |
LocalSyncTask(RepairJobDesc desc,
InetAddressAndPort local,
InetAddressAndPort remote,
java.util.List<Range<Token>> diff,
java.util.UUID pendingRepair,
boolean requestRanges,
boolean transferRanges,
PreviewKind previewKind) |
RepairResult(RepairJobDesc desc,
java.util.List<SyncStat> stats) |
StreamingRepairTask(RepairJobDesc desc,
InetAddressAndPort initiator,
InetAddressAndPort src,
InetAddressAndPort dst,
java.util.Collection<Range<Token>> ranges,
java.util.UUID pendingRepair,
PreviewKind previewKind,
boolean asymmetric) |
SymmetricRemoteSyncTask(RepairJobDesc desc,
InetAddressAndPort r1,
InetAddressAndPort r2,
java.util.List<Range<Token>> differences,
PreviewKind previewKind) |
SyncTask(RepairJobDesc desc,
InetAddressAndPort primaryEndpoint,
InetAddressAndPort peer,
java.util.List<Range<Token>> rangesToSync,
PreviewKind previewKind) |
ValidationTask(RepairJobDesc desc,
InetAddressAndPort endpoint,
int nowInSec,
PreviewKind previewKind) |
Validator(RepairJobDesc desc,
InetAddressAndPort initiator,
int nowInSec,
boolean evenTreeDistribution,
boolean isIncremental,
PreviewKind previewKind) |
Validator(RepairJobDesc desc,
InetAddressAndPort initiator,
int nowInSec,
boolean isIncremental,
PreviewKind previewKind) |
Validator(RepairJobDesc desc,
InetAddressAndPort initiator,
int nowInSec,
PreviewKind previewKind) |
Modifier and Type | Field and Description |
---|---|
RepairJobDesc |
RepairMessage.desc |
Constructor and Description |
---|
AsymmetricSyncRequest(RepairJobDesc desc,
InetAddressAndPort initiator,
InetAddressAndPort fetchingNode,
InetAddressAndPort fetchFrom,
java.util.Collection<Range<Token>> ranges,
PreviewKind previewKind) |
RepairMessage(RepairJobDesc desc) |
SnapshotMessage(RepairJobDesc desc) |
SyncRequest(RepairJobDesc desc,
InetAddressAndPort initiator,
InetAddressAndPort src,
InetAddressAndPort dst,
java.util.Collection<Range<Token>> ranges,
PreviewKind previewKind) |
SyncResponse(RepairJobDesc desc,
InetAddressAndPort endpoint1,
InetAddressAndPort endpoint2,
boolean success,
java.util.List<SessionSummary> summaries) |
SyncResponse(RepairJobDesc desc,
SyncNodePair nodes,
boolean success,
java.util.List<SessionSummary> summaries) |
ValidationRequest(RepairJobDesc desc,
int nowInSec) |
ValidationResponse(RepairJobDesc desc) |
ValidationResponse(RepairJobDesc desc,
MerkleTrees trees) |
Copyright © 2009-2020 The Apache Software Foundation