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
final class	CoordinatorState.Phase
static enum	CoordinatorState.State

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

AbstractState.UpdateType

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

AbstractCompletable.BasePhase, AbstractCompletable.BaseSkipPhase, AbstractCompletable.Status

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

Completable.Result

Field Summary

Fields

Modifier and Type	Field	Description
final int	cmd
final String	keyspace
final RepairOption	options
final 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

clock, id, lastUpdatedAtNs

Constructor Summary

Constructors

Constructor	Description
CoordinatorState(Clock clock, int cmd, String keyspace, RepairOption options)

Method Summary

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

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

getCurrentState, getStateTimesMillis, getStatus, isAccepted, maybeUpdateState, onComplete, updateState

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

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

Methods inherited from class java.lang.Object

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

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

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

Field Details

cmd

public final int cmd

keyspace

public final String keyspace

options

public final RepairOption options

phase

public final CoordinatorState.Phase phase

Constructor Details

CoordinatorState

public CoordinatorState(Clock clock,
 int cmd,
 String keyspace,
 RepairOption options)

Method Details

getSessions

public Collection<SessionState> getSessions()

getSessionIds

public Set<TimeUUID> getSessionIds()

register

public void register(SessionState state)

getColumnFamilies

public List<ColumnFamilyStore> getColumnFamilies()

getColumnFamilyNames

public String[] getColumnFamilyNames()

getNeighborsAndRanges

public RepairCoordinator.NeighborsAndRanges getNeighborsAndRanges()

getParticipants

public Set<InetAddressAndPort> getParticipants()

getCommonRanges

public List<CommonRange> getCommonRanges()

getFilteredCommonRanges

public List<CommonRange> getFilteredCommonRanges()

status

public String status()

Overrides:

status in class AbstractState<CoordinatorState.State,TimeUUID>

toString

public String toString()

Overrides:

toString in class AbstractState<CoordinatorState.State,TimeUUID>