Package | Description |
---|---|
org.apache.cassandra.db.streaming |
File transfer
|
org.apache.cassandra.exceptions | |
org.apache.cassandra.repair | |
org.apache.cassandra.repair.messages | |
org.apache.cassandra.service | |
org.apache.cassandra.streaming | |
org.apache.cassandra.streaming.messages |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<OutgoingStream> |
CassandraStreamManager.createOutgoingStreams(StreamSession session,
RangesAtEndpoint replicas,
java.util.UUID pendingRepair,
PreviewKind previewKind) |
Modifier and Type | Field and Description |
---|---|
PreviewKind |
RepairException.previewKind |
Constructor and Description |
---|
RepairException(RepairJobDesc desc,
PreviewKind previewKind,
java.lang.String message) |
Modifier and Type | Field and Description |
---|---|
PreviewKind |
RepairSession.previewKind |
protected PreviewKind |
SyncTask.previewKind |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
RepairJobDesc.toString(PreviewKind previewKind) |
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) |
RepairSession(java.util.UUID parentRepairSession,
java.util.UUID id,
CommonRange commonRange,
java.lang.String keyspace,
RepairParallelism parallelismDegree,
boolean isIncremental,
boolean pullRepair,
boolean force,
PreviewKind previewKind,
boolean optimiseStreams,
java.lang.String... cfnames)
Create new repair session.
|
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 |
---|---|
PreviewKind |
AsymmetricSyncRequest.previewKind |
PreviewKind |
PrepareMessage.previewKind |
PreviewKind |
SyncRequest.previewKind |
Modifier and Type | Method and Description |
---|---|
PreviewKind |
RepairOption.getPreviewKind() |
Constructor and Description |
---|
AsymmetricSyncRequest(RepairJobDesc desc,
InetAddressAndPort initiator,
InetAddressAndPort fetchingNode,
InetAddressAndPort fetchFrom,
java.util.Collection<Range<Token>> ranges,
PreviewKind previewKind) |
PrepareMessage(java.util.UUID parentRepairSession,
java.util.List<TableId> tableIds,
java.util.Collection<Range<Token>> ranges,
boolean isIncremental,
long timestamp,
boolean isGlobal,
PreviewKind previewKind) |
RepairOption(RepairParallelism parallelism,
boolean primaryRange,
boolean incremental,
boolean trace,
int jobThreads,
java.util.Collection<Range<Token>> ranges,
boolean isSubrangeRepair,
boolean pullRepair,
boolean forceRepair,
PreviewKind previewKind,
boolean optimiseStreams) |
SyncRequest(RepairJobDesc desc,
InetAddressAndPort initiator,
InetAddressAndPort src,
InetAddressAndPort dst,
java.util.Collection<Range<Token>> ranges,
PreviewKind previewKind) |
Modifier and Type | Field and Description |
---|---|
PreviewKind |
ActiveRepairService.ParentRepairSession.previewKind |
Modifier and Type | Method and Description |
---|---|
void |
ActiveRepairService.registerParentRepairSession(java.util.UUID parentRepairSession,
InetAddressAndPort coordinator,
java.util.List<ColumnFamilyStore> columnFamilyStores,
java.util.Collection<Range<Token>> ranges,
boolean isIncremental,
long repairedAt,
boolean isGlobal,
PreviewKind previewKind) |
RepairSession |
ActiveRepairService.submitRepairSession(java.util.UUID parentRepairSession,
CommonRange range,
java.lang.String keyspace,
RepairParallelism parallelismDegree,
boolean isIncremental,
boolean pullRepair,
boolean force,
PreviewKind previewKind,
boolean optimiseStreams,
com.google.common.util.concurrent.ListeningExecutorService executor,
java.lang.String... cfnames)
Requests repairs for the given keyspace and column families.
|
static boolean |
ActiveRepairService.verifyCompactionsPendingThreshold(java.util.UUID parentRepairSession,
PreviewKind previewKind) |
Constructor and Description |
---|
ParentRepairSession(InetAddressAndPort coordinator,
java.util.List<ColumnFamilyStore> columnFamilyStores,
java.util.Collection<Range<Token>> ranges,
boolean isIncremental,
long repairedAt,
boolean isGlobal,
PreviewKind previewKind) |
Modifier and Type | Method and Description |
---|---|
static PreviewKind |
PreviewKind.deserialize(int serializationVal) |
PreviewKind |
StreamSession.getPreviewKind() |
static PreviewKind |
PreviewKind.valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static PreviewKind[] |
PreviewKind.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
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) |
java.util.Collection<OutgoingStream> |
TableStreamManager.createOutgoingStreams(StreamSession session,
RangesAtEndpoint replicas,
java.util.UUID pendingRepair,
PreviewKind previewKind)
Returns a collection of
OutgoingStream s that contains the data selected by the
given replicas, pendingRepair, and preview. |
java.util.List<OutgoingStream> |
StreamSession.getOutgoingStreamsForRanges(RangesAtEndpoint replicas,
java.util.Collection<ColumnFamilyStore> stores,
java.util.UUID pendingRepair,
PreviewKind previewKind) |
Constructor and Description |
---|
StreamCoordinator(StreamOperation streamOperation,
int connectionsPerHost,
StreamConnectionFactory factory,
boolean follower,
boolean connectSequentially,
java.util.UUID pendingRepair,
PreviewKind previewKind) |
StreamPlan(StreamOperation streamOperation,
int connectionsPerHost,
boolean connectSequentially,
java.util.UUID pendingRepair,
PreviewKind previewKind) |
StreamSession(StreamOperation streamOperation,
InetAddressAndPort peer,
StreamConnectionFactory factory,
boolean isFollower,
int index,
java.util.UUID pendingRepair,
PreviewKind previewKind)
Create new streaming session with the peer.
|
Modifier and Type | Field and Description |
---|---|
PreviewKind |
StreamInitMessage.previewKind |
Constructor and Description |
---|
StreamInitMessage(InetAddressAndPort from,
int sessionIndex,
java.util.UUID planId,
StreamOperation streamOperation,
java.util.UUID pendingRepair,
PreviewKind previewKind) |
Copyright © 2009-2020 The Apache Software Foundation