Package org.apache.cassandra.repair.state

Class CoordinatorState

java.lang.Object

org.apache.cassandra.repair.state.AbstractCompletable<I>

org.apache.cassandra.repair.state.AbstractState<CoordinatorState.State,TimeUUID>

org.apache.cassandra.repair.state.CoordinatorState

All Implemented Interfaces:

Completable<TimeUUID>, State<CoordinatorState.State,TimeUUID>

public class CoordinatorState
extends AbstractState<CoordinatorState.State,TimeUUID>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	CoordinatorState.Phase
static class	CoordinatorState.State

Nested classes/interfaces inherited from class org.apache.cassandra.repair.state.AbstractCompletable

AbstractCompletable.BasePhase, AbstractCompletable.BaseSkipPhase

Nested classes/interfaces inherited from interface org.apache.cassandra.repair.state.Completable

Completable.Result

Field Summary

Fields

Modifier and Type	Field	Description
int	cmd
java.lang.String	keyspace
RepairOption	options
CoordinatorState.Phase	phase

Fields inherited from class org.apache.cassandra.repair.state.AbstractState

COMPLETE, currentState, INIT, stateTimesNanos

Fields inherited from class org.apache.cassandra.repair.state.AbstractCompletable

id, lastUpdatedAtNs

Constructor Summary

Constructors

Constructor	Description
CoordinatorState(int cmd, java.lang.String keyspace, RepairOption options)

Method Summary

Modifier and Type	Method	Description
java.util.List<ColumnFamilyStore>	getColumnFamilies()
java.lang.String[]	getColumnFamilyNames()
java.util.List<CommonRange>	getCommonRanges()
java.util.List<CommonRange>	getFilteredCommonRanges()
RepairRunnable.NeighborsAndRanges	getNeighborsAndRanges()
java.util.Set<InetAddressAndPort>	getParticipants()
java.util.Set<TimeUUID>	getSessionIds()
java.util.Collection<SessionState>	getSessions()
void	register(SessionState state)

Methods inherited from class org.apache.cassandra.repair.state.AbstractState

getCurrentState, getStateTimesMillis, getStatus, onComplete, updateState

Methods inherited from class org.apache.cassandra.repair.state.AbstractCompletable

getId, getInitializedAtMillis, getInitializedAtNanos, getLastUpdatedAtMillis, getLastUpdatedAtNanos, getResult, nanosToMillis, tryResult, updated

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.cassandra.repair.state.Completable

getDurationMillis, getFailureCause, getId, getInitializedAtMillis, getInitializedAtNanos, getLastUpdatedAtMillis, getLastUpdatedAtNanos, getResult, getSuccessMessage, isComplete

Field Detail

cmd

public final int cmd

keyspace

public final java.lang.String keyspace

options

public final RepairOption options

phase

public final CoordinatorState.Phase phase

Constructor Detail

CoordinatorState

public CoordinatorState(int cmd,
                        java.lang.String keyspace,
                        RepairOption options)

Method Detail

getSessions

public java.util.Collection<SessionState> getSessions()

getSessionIds

public java.util.Set<TimeUUID> getSessionIds()

register

public void register(SessionState state)

getColumnFamilies

public java.util.List<ColumnFamilyStore> getColumnFamilies()

getColumnFamilyNames

public java.lang.String[] getColumnFamilyNames()

getNeighborsAndRanges

public RepairRunnable.NeighborsAndRanges getNeighborsAndRanges()

getParticipants

public java.util.Set<InetAddressAndPort> getParticipants()

getCommonRanges

public java.util.List<CommonRange> getCommonRanges()

getFilteredCommonRanges

public java.util.List<CommonRange> getFilteredCommonRanges()