Package org.apache.cassandra.repair.consistent

Class CoordinatorSession

java.lang.Object

org.apache.cassandra.repair.consistent.ConsistentSession

org.apache.cassandra.repair.consistent.CoordinatorSession

public class CoordinatorSession
extends ConsistentSession

Coordinator side logic and state of a consistent repair session. Like ActiveRepairService.ParentRepairSession, there is only one CoordinatorSession per user repair command, regardless of the number of tables and token ranges involved.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CoordinatorSession.Builder

Nested classes/interfaces inherited from class org.apache.cassandra.repair.consistent.ConsistentSession

ConsistentSession.State

Field Summary

Fields inherited from class org.apache.cassandra.repair.consistent.ConsistentSession

coordinator, participants, ranges, repairedAt, sessionID, tableIds

Constructor Summary

Constructors

Constructor	Description
CoordinatorSession(CoordinatorSession.Builder builder)

Method Summary

Modifier and Type	Method	Description
static CoordinatorSession.Builder	builder(SharedContext ctx)
Future<CoordinatedRepairResult>	execute(Supplier<Future<CoordinatedRepairResult>> sessionSubmitter)	Runs the asynchronous consistent repair session.
void	fail()
void	finalizeCommit()
Future<Void>	finalizePropose()
void	handleFinalizePromise(Message<FinalizePromise> message)
void	handlePrepareResponse(Message<PrepareConsistentResponse> msg)
Future<Void>	prepare()
void	setParticipantState(InetAddressAndPort participant, ConsistentSession.State state)
void	setRepairing()
void	setState(ConsistentSession.State state)

Methods inherited from class org.apache.cassandra.repair.consistent.ConsistentSession

equals, getState, hashCode, intersects, isCompleted, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

CoordinatorSession

public CoordinatorSession(CoordinatorSession.Builder builder)

Method Details

builder

public static CoordinatorSession.Builder builder(SharedContext ctx)

setState

public void setState(ConsistentSession.State state)

Overrides:

setState in class ConsistentSession

setParticipantState

public void setParticipantState(InetAddressAndPort participant,
 ConsistentSession.State state)

prepare

public Future<Void> prepare()

handlePrepareResponse

public void handlePrepareResponse(Message<PrepareConsistentResponse> msg)

setRepairing

public void setRepairing()

finalizePropose

public Future<Void> finalizePropose()

handleFinalizePromise

public void handleFinalizePromise(Message<FinalizePromise> message)

finalizeCommit

public void finalizeCommit()

fail

public void fail()

execute

public Future<CoordinatedRepairResult> execute(Supplier<Future<CoordinatedRepairResult>> sessionSubmitter)

Runs the asynchronous consistent repair session. Actual repair sessions are scheduled via a submitter to make unit testing easier