Uses of Class
org.apache.cassandra.streaming.PreviewKind
-
-
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, TimeUUID pendingRepair, PreviewKind previewKind) -
Uses of PreviewKind in org.apache.cassandra.exceptions
Methods in org.apache.cassandra.exceptions with parameters of type PreviewKind Modifier and Type Method Description static RepairExceptionRepairException. error(RepairJobDesc desc, PreviewKind previewKind, java.lang.String message)static RepairExceptionRepairException. warn(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 PreviewKindRepairSession. previewKindprotected PreviewKindSyncTask. previewKindMethods in org.apache.cassandra.repair that return PreviewKind Modifier and Type Method Description PreviewKindValidator. getPreviewKind()Methods in org.apache.cassandra.repair with parameters of type PreviewKind Modifier and Type Method Description java.lang.StringRepairJobDesc. 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, TimeUUID pendingRepair, boolean requestRanges, boolean transferRanges, PreviewKind previewKind)RepairSession(TimeUUID parentRepairSession, Scheduler validationScheduler, CommonRange commonRange, java.lang.String keyspace, RepairParallelism parallelismDegree, boolean isIncremental, boolean pullRepair, PreviewKind previewKind, boolean optimiseStreams, boolean repairPaxos, boolean paxosOnly, java.lang.String... cfnames)Create new repair session.StreamingRepairTask(RepairJobDesc desc, InetAddressAndPort initiator, InetAddressAndPort src, InetAddressAndPort dst, java.util.Collection<Range<Token>> ranges, TimeUUID 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(ValidationState state, int nowInSec, boolean evenTreeDistribution, boolean isIncremental, PreviewKind previewKind)Validator(ValidationState state, int nowInSec, boolean isIncremental, PreviewKind previewKind)Validator(ValidationState state, 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 PreviewKindPrepareMessage. previewKindPreviewKindSyncRequest. previewKindMethods in org.apache.cassandra.repair.messages that return PreviewKind Modifier and Type Method Description PreviewKindRepairOption. getPreviewKind()Constructors in org.apache.cassandra.repair.messages with parameters of type PreviewKind Constructor Description PrepareMessage(TimeUUID parentRepairSession, java.util.List<TableId> tableIds, java.util.Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, 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, boolean repairPaxos, boolean paxosOnly)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.repair.state
Fields in org.apache.cassandra.repair.state declared as PreviewKind Modifier and Type Field Description PreviewKindParticipateState. previewKind -
Uses of PreviewKind in org.apache.cassandra.service
Fields in org.apache.cassandra.service declared as PreviewKind Modifier and Type Field Description PreviewKindActiveRepairService.ParentRepairSession. previewKindMethods in org.apache.cassandra.service with parameters of type PreviewKind Modifier and Type Method Description voidActiveRepairService. registerParentRepairSession(TimeUUID parentRepairSession, InetAddressAndPort coordinator, java.util.List<ColumnFamilyStore> columnFamilyStores, java.util.Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, boolean isGlobal, PreviewKind previewKind)RepairSessionActiveRepairService. submitRepairSession(TimeUUID parentRepairSession, CommonRange range, java.lang.String keyspace, RepairParallelism parallelismDegree, boolean isIncremental, boolean pullRepair, PreviewKind previewKind, boolean optimiseStreams, boolean repairPaxos, boolean paxosOnly, ExecutorPlus executor, Scheduler validationScheduler, java.lang.String... cfnames)Requests repairs for the given keyspace and column families.static booleanActiveRepairService. verifyCompactionsPendingThreshold(TimeUUID 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 PreviewKindPreviewKind. deserialize(int serializationVal)PreviewKindStreamSession. getPreviewKind()static PreviewKindPreviewKind. 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 StreamResultFutureStreamResultFuture. createFollower(int sessionIndex, TimeUUID planId, StreamOperation streamOperation, InetAddressAndPort from, StreamingChannel channel, int messagingVersion, TimeUUID pendingRepair, PreviewKind previewKind)java.util.Collection<OutgoingStream>TableStreamManager. createOutgoingStreams(StreamSession session, RangesAtEndpoint replicas, TimeUUID pendingRepair, PreviewKind previewKind)Returns a collection ofOutgoingStreams 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, TimeUUID pendingRepair, PreviewKind previewKind)Constructors in org.apache.cassandra.streaming with parameters of type PreviewKind Constructor Description StreamCoordinator(StreamOperation streamOperation, int connectionsPerHost, StreamingChannel.Factory factory, boolean follower, boolean connectSequentially, TimeUUID pendingRepair, PreviewKind previewKind)StreamPlan(StreamOperation streamOperation, int connectionsPerHost, boolean connectSequentially, TimeUUID pendingRepair, PreviewKind previewKind)StreamResultFuture(TimeUUID planId, StreamOperation streamOperation, TimeUUID pendingRepair, PreviewKind previewKind)StreamSession(StreamOperation streamOperation, InetAddressAndPort peer, StreamingChannel.Factory factory, StreamingChannel controlChannel, int messagingVersion, boolean isFollower, int index, TimeUUID 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 PreviewKindStreamInitMessage. previewKindConstructors in org.apache.cassandra.streaming.messages with parameters of type PreviewKind Constructor Description StreamInitMessage(InetAddressAndPort from, int sessionIndex, TimeUUID planId, StreamOperation streamOperation, TimeUUID pendingRepair, PreviewKind previewKind)
-