Uses of Class
org.apache.cassandra.streaming.PreviewKind
-
Packages that use PreviewKind Package Description org.apache.cassandra.db.streaming File transferorg.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 -
-
Uses of PreviewKind in org.apache.cassandra.db.streaming
Methods in org.apache.cassandra.db.streaming with parameters of type PreviewKind Modifier and Type Method Description java.util.Collection<OutgoingStream>
CassandraStreamManager. createOutgoingStreams(StreamSession session, RangesAtEndpoint replicas, java.util.UUID pendingRepair, PreviewKind previewKind)
-
Uses of PreviewKind in org.apache.cassandra.exceptions
Fields in org.apache.cassandra.exceptions declared as PreviewKind Modifier and Type Field Description PreviewKind
RepairException. previewKind
Constructors in org.apache.cassandra.exceptions with parameters of type PreviewKind Constructor Description RepairException(RepairJobDesc desc, PreviewKind previewKind, java.lang.String message)
-
Uses of PreviewKind in org.apache.cassandra.repair
Fields in org.apache.cassandra.repair declared as PreviewKind Modifier and Type Field Description PreviewKind
RepairSession. previewKind
protected PreviewKind
SyncTask. previewKind
Methods in org.apache.cassandra.repair with parameters of type PreviewKind Modifier and Type Method Description java.lang.String
RepairJobDesc. toString(PreviewKind previewKind)
Constructors in org.apache.cassandra.repair with parameters of type PreviewKind Constructor 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, 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)
-
Uses of PreviewKind in org.apache.cassandra.repair.messages
Fields in org.apache.cassandra.repair.messages declared as PreviewKind Modifier and Type Field Description PreviewKind
PrepareMessage. previewKind
PreviewKind
SyncRequest. previewKind
Methods in org.apache.cassandra.repair.messages that return PreviewKind Modifier and Type Method Description PreviewKind
RepairOption. getPreviewKind()
Constructors in org.apache.cassandra.repair.messages with parameters of type PreviewKind Constructor Description 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, boolean ignoreUnreplicatedKeyspaces)
SyncRequest(RepairJobDesc desc, InetAddressAndPort initiator, InetAddressAndPort src, InetAddressAndPort dst, java.util.Collection<Range<Token>> ranges, PreviewKind previewKind, boolean asymmetric)
-
Uses of PreviewKind in org.apache.cassandra.service
Fields in org.apache.cassandra.service declared as PreviewKind Modifier and Type Field Description PreviewKind
ActiveRepairService.ParentRepairSession. previewKind
Methods in org.apache.cassandra.service with parameters of type PreviewKind Modifier and Type Method 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, 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)
Constructors in org.apache.cassandra.service with parameters of type PreviewKind Constructor Description ParentRepairSession(InetAddressAndPort coordinator, java.util.List<ColumnFamilyStore> columnFamilyStores, java.util.Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, boolean isGlobal, PreviewKind previewKind)
-
Uses of PreviewKind in org.apache.cassandra.streaming
Methods in org.apache.cassandra.streaming that return PreviewKind Modifier and Type Method 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.Methods in org.apache.cassandra.streaming with parameters of type PreviewKind Modifier and Type Method 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 ofOutgoingStream
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)
Constructors in org.apache.cassandra.streaming with parameters of type PreviewKind Constructor 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. -
Uses of PreviewKind in org.apache.cassandra.streaming.messages
Fields in org.apache.cassandra.streaming.messages declared as PreviewKind Modifier and Type Field Description PreviewKind
StreamInitMessage. previewKind
Constructors in org.apache.cassandra.streaming.messages with parameters of type PreviewKind Constructor Description StreamInitMessage(InetAddressAndPort from, int sessionIndex, java.util.UUID planId, StreamOperation streamOperation, java.util.UUID pendingRepair, PreviewKind previewKind)
-