Package org.apache.cassandra.service

Class DataResurrectionCheck

java.lang.Object

org.apache.cassandra.service.DataResurrectionCheck

All Implemented Interfaces:

StartupCheck

public class DataResurrectionCheck
extends Object
implements StartupCheck

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DataResurrectionCheck.Heartbeat

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_HEARTBEAT_FILE
static final String	EXCLUDED_KEYSPACES_CONFIG_PROPERTY
static final String	EXCLUDED_TABLES_CONFIG_PROPERTY
static final String	HEARTBEAT_FILE_CONFIG_PROPERTY

Constructor Summary

Constructors

Constructor	Description
DataResurrectionCheck()

Method Summary

Modifier and Type	Method	Description
void	execute(StartupChecksOptions options)	Run some test to determine whether the system is safe to be started In the case where a test determines it is not safe to proceed, the test should log a message regarding the reason for the failure and ideally the steps required to remedy the problem.
Set<String>	getExcludedKeyspaces(Map<String,Object> config)
Set<Pair<String,String>>	getExcludedTables(Map<String,Object> config)
StartupChecks.StartupCheckType	getStartupCheckType()
void	postAction(StartupChecksOptions options)	Post-hook after all startup checks succeeded.

Methods inherited from class java.lang.Object

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

Field Details

HEARTBEAT_FILE_CONFIG_PROPERTY

public static final String HEARTBEAT_FILE_CONFIG_PROPERTY

See Also:

• Constant Field Values

EXCLUDED_KEYSPACES_CONFIG_PROPERTY

public static final String EXCLUDED_KEYSPACES_CONFIG_PROPERTY

See Also:

• Constant Field Values

EXCLUDED_TABLES_CONFIG_PROPERTY

public static final String EXCLUDED_TABLES_CONFIG_PROPERTY

See Also:

• Constant Field Values

DEFAULT_HEARTBEAT_FILE

public static final String DEFAULT_HEARTBEAT_FILE

See Also:

• Constant Field Values

Constructor Details

DataResurrectionCheck

public DataResurrectionCheck()

Method Details

getStartupCheckType

public StartupChecks.StartupCheckType getStartupCheckType()

Specified by:

getStartupCheckType in interface StartupCheck

Returns:

type of this startup check for configuration retrieval

execute

public void execute(StartupChecksOptions options)
             throws StartupException

Description copied from interface: StartupCheck

Run some test to determine whether the system is safe to be started In the case where a test determines it is not safe to proceed, the test should log a message regarding the reason for the failure and ideally the steps required to remedy the problem.

Specified by:

execute in interface StartupCheck

Parameters:

options - all options from descriptor

Throws:

StartupException - if the test determines that the environement or system is not in a safe state to startup

postAction

public void postAction(StartupChecksOptions options)

Description copied from interface: StartupCheck

Post-hook after all startup checks succeeded.

Specified by:

postAction in interface StartupCheck

Parameters:

options - startup check options from descriptor

getExcludedKeyspaces

public Set<String> getExcludedKeyspaces(Map<String,Object> config)

getExcludedTables

public Set<Pair<String,String>> getExcludedTables(Map<String,Object> config)