Package org.apache.cassandra.service

Class StorageService

java.lang.Object

javax.management.NotificationBroadcasterSupport

org.apache.cassandra.service.StorageService

All Implemented Interfaces:

NotificationBroadcaster, NotificationEmitter, IEndpointStateChangeSubscriber, StorageServiceMBean

public class StorageService
extends NotificationBroadcasterSupport
implements IEndpointStateChangeSubscriber, StorageServiceMBean

This abstraction contains the token/identifier of this node on the identifier space. This token gets gossiped around. This class will also maintain histograms of the load information of other nodes in the cluster.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	StorageService.Mode

Nested classes/interfaces inherited from interface org.apache.cassandra.service.StorageServiceMBean

StorageServiceMBean.StageConcurrency

Field Summary

Fields

Modifier and Type	Field	Description
static final int	INDEFINITE
static final StorageService	instance
static final AtomicInteger	nextRepairCommand
static final int	RING_DELAY_MILLIS
static final int	SCHEMA_DELAY_MILLIS
boolean	skipNotificationListeners
final SnapshotManager	snapshotManager
final SSTablesGlobalTracker	sstablesTracker
static final boolean	useStrictConsistency
VersionedValue.VersionedValueFactory	valueFactory

Constructor Summary

Constructors

Constructor	Description
StorageService()

Method Summary

Modifier and Type	Method	Description
protected void	addExpireTimeIfFound(InetAddressAndPort endpoint, long expireTime)
void	addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback)
boolean	addPostShutdownHook(Runnable hook)	Add a runnable which will be called after shutdown or drain.
boolean	addPreShutdownHook(Runnable hook)	Add a runnable which will be called before shut down or drain.
void	addSnapshot(TableSnapshot snapshot)
boolean	authSetupCalled()
boolean	autoOptimiseFullRepairStreams()
boolean	autoOptimiseIncRepairStreams()
boolean	autoOptimisePreviewRepairStreams()
Future<?>	autoRepairPaxos(TableId tableId)
void	beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)
boolean	bootstrap(Collection<Token> tokens, long bootstrapTimeoutMillis)	Bootstrap node by fetching data from other nodes.
void	bulkLoad(String directory)	Starts a bulk load and blocks until it completes.
String	bulkLoadAsync(String directory)	Starts a bulk load asynchronously and returns the String representation of the planID for the new streaming session.
void	bypassConcurrentValidatorsLimit()
void	checkForEndpointCollision(UUID localHostId, Set<InetAddressAndPort> peers)
void	cleanupSizeEstimates()	Removes extraneous entries in system.size_estimates.
void	clearConnectionHistory()	Clears the history of clients that have connected in the past
void	clearPaxosRepairs()
void	clearSnapshot(String tag, String... keyspaceNames)	Remove the snapshot with the given name from the given keyspaces.
void	clearSnapshot(Map<String,Object> options, String tag, String... keyspaceNames)	Remove the snapshot with the given name from the given keyspaces.
void	completeInitialization()
void	confirmReplication(InetAddressAndPort node)
void	decommission(boolean force)	transfer this node's data to other machines and remove it from service.
final void	deliverHints(String host)
List<TokenRange>	describeLocalRing(String keyspace)	The same as describeRing(String) but considers only the part of the ring formed by nodes in the local DC.
List<TokenRange>	describeRing(String keyspace)	The TokenRange for a given keyspace.
List<String>	describeRingJMX(String keyspace)	The same as describeRing(String) but converts TokenRange to the String for JMX compatibility
List<String>	describeRingWithPortJMX(String keyspace)
void	disableAuditLog()
void	disableAutoCompaction()
void	disableAutoCompaction(String ks, String... tables)
void	disableNativeTransportOldProtocolVersions()
void	doAuthSetup(boolean setUpSchema)
void	doAutoRepairSetup()
void	drain()	Shuts node off to writes, empties memtables and the commit log.
protected void	drain(boolean isFinalShutdown)
void	dropPreparedStatements(boolean memoryOnly)
LinkedHashMap<InetAddress,Float>	effectiveOwnership(String keyspace)	Effective ownership is % of the data each node owns given the keyspace we calculate the percentage using replication factor.
LinkedHashMap<String,Float>	effectiveOwnershipWithPort(String keyspace)
void	enableAuditLog(String loggerName, String includedKeyspaces, String excludedKeyspaces, String includedCategories, String excludedCategories, String includedUsers, String excludedUsers)	Deprecated. See CASSANDRA-16725
void	enableAuditLog(String loggerName, String includedKeyspaces, String excludedKeyspaces, String includedCategories, String excludedCategories, String includedUsers, String excludedUsers, Integer maxArchiveRetries, Boolean block, String rollCycle, Long maxLogSize, Integer maxQueueWeight, String archiveCommand)
void	enableAuditLog(String loggerName, Map<String,String> parameters, String includedKeyspaces, String excludedKeyspaces, String includedCategories, String excludedCategories, String includedUsers, String excludedUsers)	Deprecated. See CASSANDRA-16725
void	enableAuditLog(String loggerName, Map<String,String> parameters, String includedKeyspaces, String excludedKeyspaces, String includedCategories, String excludedCategories, String includedUsers, String excludedUsers, Integer maxArchiveRetries, Boolean block, String rollCycle, Long maxLogSize, Integer maxQueueWeight, String archiveCommand)
void	enableAutoCompaction(String ks, String... tables)
void	enableFullQueryLogger(String path, String rollCycle, Boolean blocking, int maxQueueWeight, long maxLogSize, String archiveCommand, int maxArchiveRetries)	Start the fully query logger.
void	enableNativeTransportOldProtocolVersions()
void	enforceConcurrentValidatorsLimit()
void	evictHungRepairs()
protected long	extractExpireTime(String[] pieces)
void	finishJoiningRing(boolean didBootstrap, Collection<Token> tokens)
void	forceCompactionKeysIgnoringGcGrace(String keyspaceName, String tableName, String... partitionKeysIgnoreGcGrace)	Forces compaction for a list of partition keys in a table The method will ignore the gc_grace_seconds for the partitionKeysIgnoreGcGrace during the comapction, in order to purge the tombstones and free up space quicker.
int	forceKeyspaceCleanup(int jobs, String keyspaceName, String... tableNames)
int	forceKeyspaceCleanup(String keyspaceName, String... tables)	Trigger a cleanup of keys on a single keyspace
void	forceKeyspaceCompaction(boolean splitOutput, String keyspaceName, String... tableNames)	Forces major compaction of a single keyspace
void	forceKeyspaceCompactionForPartitionKey(String keyspaceName, String partitionKey, String... tableNames)	Forces major compactions for the range represented by the partition key
void	forceKeyspaceCompactionForTokenRange(String keyspaceName, String startToken, String endToken, String... tableNames)	Forces major compaction of specified token range in a single keyspace.
void	forceKeyspaceFlush(String keyspaceName, String... tableNames)	Flush all memtables for a keyspace and column families.
void	forceKeyspaceFlush(String keyspaceName, ColumnFamilyStore.FlushReason reason)	Flush all memtables for a keyspace and column families.
void	forceRemoveCompletion()	Force a remove operation to complete.
void	forceTerminateAllRepairSessions()
int	garbageCollect(String tombstoneOptionString, int jobs, String keyspaceName, String... tableNames)	Rewrites all sstables from the given tables to remove deleted data.
String[]	getAllDataFileLocations()	Get the list of all data file locations from conf
List<Range<Token>>	getAllRanges(List<Token> sortedTokens)	Get all ranges that span the ring given a set of tokens.
Map<String,Boolean>	getAutoCompactionStatus(String ks, String... tables)
String	getBatchlogEndpointStrategy()
int	getBatchlogReplayThrottleInKB()
int	getBatchSizeFailureThreshold()	Returns the threshold for rejecting queries due to a large batch size
int	getBatchSizeWarnThreshold()	Deprecated. See CASSANDRA-17668
int	getBatchSizeWarnThresholdInKiB()	Returns the threshold for warning queries due to a large batch size
String	getBootstrapState()
int	getCachedReplicaRowsFailThreshold()	Returns the number of rows cached at the coordinator before filtering/index queries fail outright.
int	getCachedReplicaRowsWarnThreshold()	Returns the number of rows cached at the coordinator before filtering/index queries log a warning.
long	getCasContentionTimeout()
String	getClusterName()	Returns the name of the cluster
int	getColumnIndexCacheSize()	Deprecated. See CASSANDRA-17668
int	getColumnIndexCacheSizeInKiB()	Returns the threshold for skipping the column index when caching partition info
int	getColumnIndexSizeInKiB()	Returns the granularity of the collation index of rows within a partition.
String	getCommitLogLocation()	Get location of the commit log
int	getCompactionThroughputMbPerSec()	Deprecated. See CASSANDRA-17225
long	getCompactionThroughtputBytesPerSec()
double	getCompactionThroughtputMibPerSecAsDouble()
int	getCompactionTombstoneWarningThreshold()
int	getCompressedReadAheadBufferInKB()
Map<String,List<Integer>>	getConcurrency(List<String> stageNames)
int	getConcurrentCompactors()
int	getConcurrentIndexBuilders()
int	getConcurrentValidators()
int	getConcurrentViewBuilders()
String	getCoordinatorLargeReadAbortThreshold()
String	getCoordinatorLargeReadWarnThreshold()
String	getCorruptedTombstoneStrategy()
long	getCounterWriteRpcTimeout()
int	getCurrentGenerationNumber()	Return the generation value for this node.
int	getDefaultKeyspaceReplicationFactor()
String	getDrainProgress()	get the progress of a drain operation
int	getDynamicUpdateInterval()
InetAddressAndPort	getEndpointForHostId(UUID hostId)
Map<String,String>	getEndpointToHostId()	Retrieve the mapping of endpoint to host ID.
Map<String,String>	getEndpointWithPortToHostId()
boolean	getEnforceNativeDeadlineForHints()
double	getEntireSSTableInterDCStreamThroughputMebibytesPerSecAsDouble()
double	getEntireSSTableStreamThroughputMebibytesPerSecAsDouble()
boolean	getForceOptimizedIndexStatusFormat()
CompositeData	getFullQueryLoggerOptions()	Returns the current state of FQL.
String	getGitSHA()	Fetch a string representation of the Cassandra git SHA.
UUID	getHostIdForEndpoint(InetAddressAndPort address)
Map<String,String>	getHostIdMap()
Map<String,String>	getHostIdToEndpoint()	Retrieve the mapping of host ID to endpoint.
Map<String,String>	getHostIdToEndpointWithPort()
int	getInitialRangeTombstoneListAllocationSize()	Returns the initial allocation size of backing arrays for new RangeTombstoneList objects
int	getInterDCStreamThroughputMbitPerSec()	Deprecated. See CASSANDRA-17225
double	getInterDCStreamThroughputMbitPerSecAsDouble()
int	getInterDCStreamThroughputMbPerSec()	Deprecated. See CASSANDRA-15234
int	getInterDCStreamThroughputMebibytesPerSec()	Below method returns Inter_dc_stream_throughput_outbound rounded, for precise number, please, use getInterDCStreamThroughputMebibytesPerSecAsDouble
double	getInterDCStreamThroughputMebibytesPerSecAsDouble()
int	getInternodeStreamingTcpUserTimeoutInMS()
int	getInternodeTcpConnectTimeoutInMS()
int	getInternodeTcpUserTimeoutInMS()
boolean	getInvalidateKeycacheOnSSTableDeletion()
List<String>	getJoiningNodes()	Deprecated. See CASSANDRA-7544
List<String>	getJoiningNodesWithPort()
DecoratedKey	getKeyFromPartition(String keyspaceName, String table, String partitionKey)
int	getKeyspaceCountWarnThreshold()	Deprecated. See CASSANDRA-17195
String	getKeyspaceReplicationInfo(String keyspaceName)	Fetch the replication factor for a given keyspace.
List<String>	getKeyspaces()
List<String>	getLeavingNodes()	Deprecated. See CASSANDRA-7544
List<String>	getLeavingNodesWithPort()
List<String>	getLiveNodes()	Deprecated. See CASSANDRA-7544
List<String>	getLiveNodesWithPort()
Set<InetAddressAndPort>	getLiveRingMembers()
Set<InetAddressAndPort>	getLiveRingMembers(boolean excludeDeadStates)
Map<String,String>	getLoadMap()	Human-readable load value.
Map<String,String>	getLoadMapWithPort()
String	getLoadString()	Human-readable load value
List<Range<Token>>	getLocalAndPendingRanges(String ks)
String	getLocalHostId()	Retrieve this hosts unique ID
UUID	getLocalHostUUID()
Collection<Range<Token>>	getLocalPrimaryRange()
Collection<Range<Token>>	getLocalPrimaryRangeForEndpoint(InetAddressAndPort referenceEndpoint)
List<Range<Token>>	getLocalRanges(String ks)
String	getLocalReadTooLargeAbortThreshold()
String	getLocalReadTooLargeWarnThreshold()
RangesAtEndpoint	getLocalReplicas(String keyspaceName)
String[]	getLocalSystemKeyspacesDataFileLocations()	Returns the locations where the local system keyspaces data should be stored.
Collection<Token>	getLocalTokens()
Map<String,String>	getLoggingLevels()	get the runtime logging levels
int	getMaxHintTTL()	Returns upper bound on the hint ttl
int	getMaxTopSizePartitionCount()
int	getMaxTopTombstonePartitionCount()
boolean	getMigrateKeycacheOnCompaction()
String	getMinTrackedPartitionSize()
long	getMinTrackedPartitionTombstoneCount()
List<String>	getMovingNodes()	Deprecated. See CASSANDRA-7544
List<String>	getMovingNodesWithPort()
String	getNativeaddress(InetAddressAndPort endpoint, boolean withPort)	Return the native address associated with an endpoint as a string.
long	getNativeTransportMaxBackoffOnQueueOverloadInMillis()
long	getNativeTransportMaxConcurrentRequestsInBytes()
long	getNativeTransportMaxConcurrentRequestsInBytesPerIp()
int	getNativeTransportMaxRequestsPerSecond()
long	getNativeTransportMinBackoffOnQueueOverloadInMillis()
double	getNativeTransportQueueMaxItemAgeThreshold()
boolean	getNativeTransportRateLimitingEnabled()
boolean	getNativeTransportThrowOnOverload()
long	getNativeTransportTimeoutMillis()
List<InetAddress>	getNaturalEndpoints(String keyspaceName, String cf, String key)	Deprecated. See CASSANDRA-7544
List<InetAddress>	getNaturalEndpoints(String keyspaceName, ByteBuffer key)	Deprecated. See CASSANDRA-7544
List<String>	getNaturalEndpointsWithPort(String keyspaceName, String cf, String key)
List<String>	getNaturalEndpointsWithPort(String keyspaceName, ByteBuffer key)
EndpointsForToken	getNaturalReplicasForToken(String keyspaceName, String cf, String key)
EndpointsForToken	getNaturalReplicasForToken(String keyspaceName, ByteBuffer key)
List<String>	getNonLocalStrategyKeyspaces()
String[]	getNonLocalSystemKeyspacesDataFileLocations()	Returns the locations where should be stored the non system keyspaces data.
List<String>	getNonSystemKeyspaces()
OwnedRanges	getNormalizedLocalRanges(String keyspaceName)
OwnedRanges	getNormalizedRanges(String keyspaceName, InetAddressAndPort ep)
String	getOperationMode()	get the operational mode (leaving, joining, normal, decommissioned, client)
Map<String,long[]>	getOutOfRangeOperationCounts()	Get the per-keyspace counts of operations that the node has received for tokens outside its owned ranges.
Map<String,Set<InetAddress>>	getOutstandingSchemaVersions()	Returns a map of schema version -> list of endpoints reporting that version that we need schema updates for
Map<String,Set<String>>	getOutstandingSchemaVersionsWithPort()
Map<InetAddress,Float>	getOwnership()	given a list of tokens (representing the nodes in the cluster), returns a mapping from "token -> %age of cluster owned by that token"
Map<String,Float>	getOwnershipWithPort()
List<String>	getParentRepairStatus(int cmd)	Get the status of a given parent repair session.
String	getPartitionerName()	Returns the cluster partitioner
boolean	getPaxosAutoRepairsEnabled()
List<String>	getPaxosAutoRepairTables()
String	getPaxosBallotLowBound(String ksName, String tblName, String key)
boolean	getPaxosDcLocalCommitEnabled()
String	getPaxosOnLinearizabilityViolations()
long	getPaxosPurgeGraceSeconds()
boolean	getPaxosRepairEnabled()
boolean	getPaxosRepairRaceWait()
boolean	getPaxosStateFlushEnabled()
String	getPaxosStatePurging()
Map<List<String>,List<String>>	getPendingRangeToEndpointMap(String keyspace)	Retrieve a map of pending ranges to endpoints that describe the ring topology
Map<List<String>,List<String>>	getPendingRangeToEndpointWithPortMap(String keyspace)
List<Pair<String,String>>	getPreparedStatements()
Collection<Range<Token>>	getPrimaryRangeForEndpointWithinDC(String keyspace, InetAddressAndPort referenceEndpoint)	Get the "primary ranges" within local DC for the specified keyspace and endpoint.
Collection<Range<Token>>	getPrimaryRanges(String keyspace)
Collection<Range<Token>>	getPrimaryRangesForEndpoint(String keyspace, InetAddressAndPort ep)	Get the "primary ranges" for the specified keyspace and endpoint.
Collection<Range<Token>>	getPrimaryRangesWithinDC(String keyspace)
boolean	getPrioritizeSAIOverLegacyIndex()
long	getRangeRpcTimeout()
EndpointsByRange	getRangeToAddressMap(String keyspace)
EndpointsByRange	getRangeToAddressMapInLocalDC(String keyspace)
Map<List<String>,List<String>>	getRangeToEndpointMap(String keyspace)	Retrieve a map of range to end points that describe the ring topology of a Cassandra cluster.
Map<List<String>,List<String>>	getRangeToEndpointMap(String keyspace, boolean withPort)	for a keyspace, return the ranges and corresponding listen addresses.
Map<List<String>,List<String>>	getRangeToEndpointWithPortMap(String keyspace)
double	getRangeTombstoneResizeListGrowthFactor()	Returns the resize factor to use when growing/resizing a RangeTombstoneList
Map<List<String>,List<String>>	getRangeToNativeaddressWithPortMap(String keyspace)
Map<List<String>,List<String>>	getRangeToRpcaddressMap(String keyspace)	Retrieve a map of range to rpc addresses that describe the ring topology of a Cassandra cluster.
long	getReadRpcTimeout()
boolean	getReadThresholdsEnabled()
String	getReleaseVersion()	Fetch a string representation of the Cassandra version.
String	getRemovalStatus()	Get the status of a token removal.
String	getRemovalStatusWithPort()
Long	getRepairRpcTimeout()
int	getRepairSessionMaximumTreeDepth()
int	getRepairSessionMaxTreeDepth()	Deprecated. See CASSANDRA-17668
RangesAtEndpoint	getReplicas(String keyspaceName, InetAddressAndPort endpoint)
RangesAtEndpoint	getReplicas(AbstractReplicationStrategy replicationStrategy, InetAddressAndPort endpoint)
String	getRowIndexReadSizeAbortThreshold()
String	getRowIndexReadSizeWarnThreshold()
long	getRpcTimeout()
List<String>	getSampleTasks()
String	getSavedCachesLocation()	Get location of the saved caches dir
String	getSchemaVersion()	Fetch a string representation of the current Schema version.
boolean	getSkipPaxosRepairCompatibilityCheck()
boolean	getSkipPaxosRepairOnTopologyChange()
String	getSkipPaxosRepairOnTopologyChangeKeyspaces()
boolean	getSkipStreamDiskSpaceCheck()
Map<String,TabularData>	getSnapshotDetails()	Deprecated. See CASSANDRA-16789
Map<String,TabularData>	getSnapshotDetails(Map<String,String> options)	Get the details of all the snapshots
long	getSnapshotLinksPerSecond()	Get the current hardlink-per-second throttle for snapshots A setting of zero indicates no throttling.
List<Pair<Range<Token>,Long>>	getSplits(String keyspaceName, String cfName, Range<Token> range, int keysPerSplit)
int	getSSTablePreemptiveOpenIntervalInMB()	This method can return negative number for disabled
int	getStreamThroughputMbitPerSec()	Deprecated. See CASSANDRA-17225
double	getStreamThroughputMbitPerSecAsDouble()
int	getStreamThroughputMbPerSec()	Deprecated. See CASSANDRA-15234
int	getStreamThroughputMebibytesPerSec()	Below method returns stream_throughput_outbound rounded, for precise number, please, use getStreamThroughputMebibytesPerSecAsDouble
double	getStreamThroughputMebibytesPerSecAsDouble()
int	getTableCountWarnThreshold()	Deprecated. See CASSANDRA-17195
List<String>	getTablesForKeyspace(String keyspace)	Gets the names of all tables for the given keyspace
String	getToken(String keyspaceName, String table, String key)
Token.TokenFactory	getTokenFactory()
TokenMetadata	getTokenMetadata()
List<String>	getTokens()	Fetch string representations of the tokens for this node.
List<String>	getTokens(String endpoint)	Fetch string representations of the tokens for a specified node.
Collection<Token>	getTokensFor(InetAddressAndPort endpoint)
Map<String,String>	getTokenToEndpointMap()	Retrieve a map of tokens to endpoints, including the bootstrapping ones.
Map<String,String>	getTokenToEndpointWithPortMap()
int	getTombstoneFailureThreshold()	Returns the threshold for abandoning queries with many tombstones
int	getTombstoneWarnThreshold()	Returns the threshold for warning of queries with many tombstones
double	getTraceProbability()	Returns the configured tracing probability.
boolean	getTransferHintsOnDecommission()
long	getTruncateRpcTimeout()
String	getUncompressedLoadString()	Human-readable uncompressed load value
List<String>	getUnreachableNodes()	Deprecated. See CASSANDRA-7544
List<String>	getUnreachableNodesWithPort()
Iterable<ColumnFamilyStore>	getValidColumnFamilies(boolean allowIndexes, boolean autoAddIndexes, String keyspaceName, String... cfNames)
Map<String,String>	getViewBuildStatuses(String keyspace, String view)
Map<String,String>	getViewBuildStatuses(String keyspace, String view, boolean withPort)
Map<String,String>	getViewBuildStatusesWithPort(String keyspace, String view)
long	getWriteRpcTimeout()
void	gossipSnitchInfo()
boolean	hasJoined()
void	incOutOfRangeOperationCount()
void	initServer()
void	initServer(int schemaAndRingDelayMillis)
void	initServer(int schemaTimeoutMillis, int ringTimeoutMillis)
boolean	isAuditLogEnabled()
boolean	isAuthSetupComplete()
boolean	isBootstrapFailed()	Returns whether a node has failed to bootstrap.
boolean	isBootstrapMode()	Check if currently bootstrapping.
boolean	isConcurrentValidatorsLimitEnforced()
boolean	isDaemonSetupCompleted()
boolean	isDecommissioned()
boolean	isDecommissionFailed()	Returns whether a node has failed to decommission.
boolean	isDecommissioning()	Returns whether a node is being decommissioned or not.
boolean	isDrained()
boolean	isDraining()
boolean	isEndpointValidForWrite(String keyspace, Token token)
boolean	isFullQueryLogEnabled()
boolean	isGossipActive()
boolean	isGossipRunning()
boolean	isHintTtlUseMutationCreationTime()	Returns whether we are using the creation time of the mutation for determining hint ttl
boolean	isIncrementalBackupsEnabled()
boolean	isInitialized()
boolean	isInShutdownHook()	Deprecated. See CASSANDRA-12509
boolean	isJoined()
boolean	isJoining()
boolean	isMoving()
boolean	isNativeTransportRunning()
boolean	isNormal()
boolean	isOutOfTokenRangeRequestLoggingEnabled()	Toggles to turn on the logging or rejection of operations for token ranges that the node does not own, or is not about to acquire.
boolean	isOutOfTokenRangeRequestRejectionEnabled()
boolean	isReplacing()
static boolean	isReplacingSameAddress()
boolean	isReplacingSameHostAddressAndHostId(UUID hostId)
boolean	isRpcReady(InetAddressAndPort endpoint)
static boolean	isSeed()
boolean	isShutdown()
boolean	isStarting()	Returns whether the storage service is starting or not
boolean	isSurveyMode()
void	joinRing()
void	joinTokenRing(boolean finishJoiningRing, boolean shouldBootstrap, long schemaTimeoutMillis, long bootstrapTimeoutMillis, long ringTimeoutMillis)
void	loadNewSSTables(String ksName, String cfName)	Deprecated. See CASSANDRA-14417
void	move(String newToken)
List<String>	mutateSSTableRepairedState(boolean repaired, boolean preview, String keyspace, List<String> tableNames)	Mutates the repaired state of all SSTables for the given SSTables
void	onAlive(InetAddressAndPort endpoint, EndpointState state)
void	onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)
void	onDead(InetAddressAndPort endpoint, EndpointState state)
void	onJoin(InetAddressAndPort endpoint, EndpointState epState)	Use to inform interested parties about the change in the state for specified endpoint
void	onRemove(InetAddressAndPort endpoint)
void	onRestart(InetAddressAndPort endpoint, EndpointState state)	Called whenever a node is restarted.
void	populateTokenMetadata()
Collection<InetAddressAndPort>	prepareForBootstrap(long schemaTimeoutMillis, long ringTimeoutMillis)
Supplier<Future<StreamState>>	prepareUnbootstrapStreaming()
void	rebuild(String sourceDc)	Initiate a process of streaming data for which we are responsible from other nodes.
void	rebuild(String sourceDc, String keyspace, String tokens, String specificSources)	Same as StorageServiceMBean.rebuild(String), but only for specified keyspace and ranges.
void	rebuild(String sourceDc, String keyspace, String tokens, String specificSources, boolean excludeLocalDatacenterNodes)	Same as StorageServiceMBean.rebuild(String), but only for specified keyspace and ranges.
void	rebuildSecondaryIndex(String ksName, String cfName, String... idxNames)	rebuild the specified indexes
int	recompressSSTables(String keyspaceName, int jobs, String... tableNames)
void	refreshSizeEstimates()	Forces refresh of values stored in system.size_estimates of all column families.
void	register(IEndpointLifecycleSubscriber subscriber)
void	registerDaemon(CassandraDaemon daemon)
void	reloadLocalSchema()
int	relocateSSTables(int jobs, String keyspaceName, String... tableNames)
int	relocateSSTables(String keyspaceName, String... tableNames)
void	removeNode(String hostIdString)	Remove a node that has died, attempting to restore the replica count.
void	removeNotificationListener(NotificationListener listener)
void	removeNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback)
boolean	removePostShutdownHook(Runnable hook)	Remove a postshutdownhook
boolean	removePreShutdownHook(Runnable hook)	Remove a preshutdown hook
void	removeShutdownHook()	In the event of forceful termination we need to remove the shutdown hook to prevent hanging (OOM for instance)
Pair<Integer,Future<?>>	repair(String keyspace, Map<String,String> repairSpec, List<ProgressListener> listeners)
Pair<Integer,Future<?>>	repair(String keyspace, RepairOption option, List<ProgressListener> listeners)
int	repairAsync(String keyspace, Map<String,String> repairSpec)	Invoke repair asynchronously.
void	rescheduleFailedDeletions()
void	resetFullQueryLogger()	Disable the full query logger if it is enabled.
void	resetLocalSchema()
boolean	resumeBootstrap()	Resume bootstrap streaming when there is failed data streaming.
int	rewriteSSTables(String keyspaceName, boolean skipIfCurrentVersion, long skipIfNewerThanTimestamp, boolean skipIfCompressionMatches, int jobs, String... tableNames)
List<String>	sampleKeyRange()	#Return a List of Tokens representing a sample of keys across all ColumnFamilyStores.
Map<String,List<CompositeData>>	samplePartitions(int duration, int capacity, int count, List<String> samplers)
Map<String,List<CompositeData>>	samplePartitions(String keyspace, int durationMillis, int capacity, int count, List<String> samplers)
int	scrub(boolean disableSnapshot, boolean skipCorrupted, boolean checkData, boolean reinsertOverflowedTTL, int jobs, String keyspaceName, String... tableNames)
int	scrub(boolean disableSnapshot, IScrubber.Options options, int jobs, String keyspaceName, String... tableNames)
void	setAutoOptimiseFullRepairStreams(boolean enabled)
void	setAutoOptimiseIncRepairStreams(boolean enabled)
void	setAutoOptimisePreviewRepairStreams(boolean enabled)
void	setBatchlogEndpointStrategy(String batchlogEndpointStrategy)	See Config.BatchlogEndpointStrategy for valid values.
void	setBatchlogReplayThrottleInKB(int throttleInKB)
void	setBatchSizeFailureThreshold(int threshold)	Sets the threshold for rejecting queries due to a large batch size
void	setBatchSizeWarnThreshold(int threshold)	Deprecated. See CASSANDRA-17668
void	setBatchSizeWarnThresholdInKiB(int thresholdInKiB)	Sets the threshold for warning queries due to a large batch size
void	setCachedReplicaRowsFailThreshold(int threshold)	Sets the number of rows cached at the coordinator before filtering/index queries fail outright.
void	setCachedReplicaRowsWarnThreshold(int threshold)	Sets the number of rows cached at the coordinator before filtering/index queries log a warning.
void	setCasContentionTimeout(long value)
void	setColumnIndexCacheSize(int cacheSizeInKB)	Deprecated. See CASSANDRA-17668
void	setColumnIndexCacheSizeInKiB(int cacheSizeInKiB)	Sets the threshold for skipping the column index when caching partition info
void	setColumnIndexSize(int columnIndexSizeInKB)	Deprecated. See CASSANDRA-17668
void	setColumnIndexSizeInKiB(int columnIndexSizeInKiB)	Sets the granularity of the collation index of rows within a partition.
void	setCompactionThroughputMbPerSec(int value)
void	setCompactionTombstoneWarningThreshold(int count)
void	setCompressedReadAheadBufferInKB(int sizeInKb)
void	setConcurrency(String threadPoolName, int newCorePoolSize, int newMaximumPoolSize)	Sets the concurrency setting for processing stages
void	setConcurrentCompactors(int value)
void	setConcurrentIndexBuilders(int value)
void	setConcurrentValidators(int value)
void	setConcurrentViewBuilders(int value)
void	setCoordinatorLargeReadAbortThreshold(String threshold)
void	setCoordinatorLargeReadWarnThreshold(String threshold)
void	setCorruptedTombstoneStrategy(String strategy)
void	setCounterWriteRpcTimeout(long value)
void	setDefaultKeyspaceReplicationFactor(int value)
void	setDynamicUpdateInterval(int dynamicUpdateInterval)
void	setEnforceNativeDeadlineForHints(boolean value)
void	setEntireSSTableInterDCStreamThroughputMebibytesPerSec(int value)
void	setEntireSSTableStreamThroughputMebibytesPerSec(int value)
void	setForceOptimizedIndexStatusFormat(boolean value)
void	setGossipTokens(Collection<Token> tokens)
void	setHintedHandoffThrottleInKB(int throttleInKB)	Sets the hinted handoff throttle in KiB per second, per delivery thread.
void	setIncrementalBackupsEnabled(boolean value)
void	setInitialRangeTombstoneListAllocationSize(int size)	Sets the initial allocation size of backing arrays for new RangeTombstoneList objects
void	setInterDCStreamThroughputMbitPerSec(int value)
void	setInterDCStreamThroughputMbPerSec(int value)	Deprecated. See CASSANDRA-15234
void	setInterDCStreamThroughputMebibytesPerSec(int value)
void	setInternodeStreamingTcpUserTimeoutInMS(int value)
void	setInternodeTcpConnectTimeoutInMS(int value)
void	setInternodeTcpUserTimeoutInMS(int value)
void	setInvalidateKeycacheOnSSTableDeletion(boolean invalidate)
void	setIsShutdownUnsafeForTests(boolean isShutdown)	for in-jvm dtest use - forces isShutdown to be set to whatever passed in.
void	setKeyspaceCountWarnThreshold(int value)	Deprecated. See CASSANDRA-17195
void	setLocalReadTooLargeAbortThreshold(String threshold)
void	setLocalReadTooLargeWarnThreshold(String threshold)
void	setLoggingLevel(String classQualifier, String rawLevel)	set the logging level at runtime If both classQualifer and level are empty/null, it will reload the configuration to reset. If classQualifer is not empty but level is empty/null, it will set the level to null for the defined classQualifer If level cannot be parsed, then the level will be defaulted to DEBUG
void	setMaxHintTTL(int maxHintTTL)	Sets the upper bound on the hint ttl
void	setMaxTopSizePartitionCount(int value)
void	setMaxTopTombstonePartitionCount(int value)
void	setMigrateKeycacheOnCompaction(boolean invalidateKeyCacheOnCompaction)
void	setMinTrackedPartitionSize(String value)
void	setMinTrackedPartitionTombstoneCount(long value)
void	setMovingModeUnsafe()
void	setNativeTransportBackoffOnQueueOverloadInMillis(long min, long max)
void	setNativeTransportMaxConcurrentRequestsInBytes(long newLimit)
void	setNativeTransportMaxConcurrentRequestsInBytesPerIp(long newLimit)
void	setNativeTransportMaxRequestsPerSecond(int newPerSecond)
void	setNativeTransportQueueMaxItemAgeThreshold(double threshold)
void	setNativeTransportRateLimitingEnabled(boolean enabled)
void	setNativeTransportThrowOnOverload(boolean throwOnOverload)
void	setNativeTransportTimeoutMillis(long deadlineMillis)
void	setNormalModeUnsafe()	Only used in jvm dtest when not using GOSSIP.
void	setOutOfTokenRangeRequestLoggingEnabled(boolean enabled)
void	setOutOfTokenRangeRequestRejectionEnabled(boolean enabled)
IPartitioner	setPartitionerUnsafe(IPartitioner newPartitioner)
void	setPaxosAutoRepairsEnabled(boolean enabled)
void	setPaxosDcLocalCommitEnabled(boolean enabled)
void	setPaxosOnLinearizabilityViolations(String v)
void	setPaxosPurgeGraceSeconds(long v)
void	setPaxosRepairEnabled(boolean enabled)
void	setPaxosRepairRaceWait(boolean paxosRepairRaceWait)
void	setPaxosStateFlushEnabled(boolean enabled)
void	setPaxosStatePurging(String v)
void	setPrioritizeSAIOverLegacyIndex(boolean value)
void	setRangeRpcTimeout(long value)
void	setRangeTombstoneListResizeGrowthFactor(double growthFactor)	Sets the resize factor to use when growing/resizing a RangeTombstoneList
void	setReadRpcTimeout(long value)
void	setReadThresholdsEnabled(boolean value)
void	setRepairRpcTimeout(Long timeoutInMillis)
void	setRepairSessionMaximumTreeDepth(int depth)
void	setRepairSessionMaxTreeDepth(int depth)	Deprecated. See CASSANDRA-17668
void	setRowIndexReadSizeAbortThreshold(String threshold)
void	setRowIndexReadSizeWarnThreshold(String threshold)
void	setRpcReady(boolean value)	Set the RPC status.
void	setRpcTimeout(long value)
void	setSkipPaxosRepairCompatibilityCheck(boolean v)
void	setSkipPaxosRepairOnTopologyChange(boolean v)
void	setSkipPaxosRepairOnTopologyChangeKeyspaces(String v)
void	setSkipStreamDiskSpaceCheck(boolean value)
void	setSnapshotLinksPerSecond(long throttle)	Set the current hardlink-per-second throttle for snapshots A setting of zero indicates no throttling
void	setSSTablePreemptiveOpenIntervalInMB(int intervalInMB)	Negative number for disabled
void	setStartingModeUnsafe()
void	setStreamThroughputMbitPerSec(int value)
void	setStreamThroughputMbPerSec(int value)	Deprecated. See CASSANDRA-15234
void	setStreamThroughputMebibytesPerSec(int value)
void	setTableCountWarnThreshold(int value)	Deprecated. See CASSANDRA-17195
void	setTokens(Collection<Token> tokens)	This method updates the local token on disk
void	setTombstoneFailureThreshold(int threshold)	Sets the threshold for abandoning queries with many tombstones
void	setTombstoneWarnThreshold(int threshold)	Sets the threshold for warning queries with many tombstones
void	setTraceProbability(double probability)	Enables/Disables tracing for the whole system.
void	setTransferHintsOnDecommission(boolean enabled)
void	setTruncateRpcTimeout(long value)
void	setUpDistributedSystemKeyspaces()
void	setUseCreationTimeForHintTtl(boolean enabled)	Sets whether we are using the creation time of the mutation for determining hint ttl
void	setWriteRpcTimeout(long value)
boolean	shouldTraceProbablistically()
void	shutdownServer()
Future<StreamState>	startBootstrap(Collection<Token> tokens)
Future<StreamState>	startBootstrap(Collection<Token> tokens, boolean replacing)
void	startGossiping()
void	startNativeTransport()
Future<?>	startRepairPaxosForTopologyChange(String reason)
boolean	startSamplingPartitions(String ks, String table, int duration, int interval, int capacity, int count, List<String> samplers)	Start a scheduled sampling
void	startSnapshotManager()
void	stopClient()
void	stopDaemon()
void	stopFullQueryLogger()	Stop logging queries but leave any generated files on disk.
void	stopGossiping()
void	stopNativeTransport(boolean force)
boolean	stopSamplingPartitions(String ks, String table)	Stop a scheduled sampling
void	stopTransports()
void	takeMultipleTableSnapshot(String tag, String... tableList)	Takes the snapshot of a multiple column family from different keyspaces.
void	takeSnapshot(String tag, String... keyspaceNames)	Takes the snapshot for the given keyspaces.
void	takeSnapshot(String tag, Map<String,String> options, String... entities)	Takes the snapshot of a multiple column family from different keyspaces.
void	takeTableSnapshot(String keyspaceName, String tableName, String tag)	Takes the snapshot of a specific table.
boolean	topPartitionsEnabled()
long	trueSnapshotsSize()	Get the true size taken by all snapshots across all keyspaces.
void	truncate(String keyspace, String table)	Truncates (deletes) the given table from the provided keyspace.
void	unregister(IEndpointLifecycleSubscriber subscriber)
void	unsafeInitialize()
void	updateSnitch(String epSnitchClassName, Boolean dynamic, Integer dynamicUpdateInterval, Integer dynamicResetInterval, Double dynamicBadnessThreshold)	Change endpointsnitch class and dynamic-ness (and dynamic attributes) at runtime.
void	updateTopology()
void	updateTopology(InetAddressAndPort endpoint)
int	upgradeSSTables(String keyspaceName, boolean skipIfCurrentVersion, long skipIfNewerThanTimestamp, int jobs, String... tableNames)
int	upgradeSSTables(String keyspaceName, boolean excludeCurrentVersion, String... tableNames)	Rewrite all sstables to the latest version.
int	verify(boolean extendedVerify, boolean checkVersion, boolean diskFailurePolicy, boolean mutateRepairStatus, boolean checkOwnsTokens, boolean quick, String keyspaceName, String... tableNames)
int	verify(boolean extendedVerify, String keyspaceName, String... tableNames)	Deprecated. See CASSANDRA-14201
void	waitForSchema(long schemaTimeoutMillis, long ringTimeoutMillis)

Methods inherited from class javax.management.NotificationBroadcasterSupport

getNotificationInfo, handleNotification, sendNotification

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.management.NotificationBroadcaster

getNotificationInfo

Methods inherited from interface org.apache.cassandra.service.StorageServiceMBean

scrub, scrub, stopNativeTransport, upgradeSSTables

Field Details

INDEFINITE

public static final int INDEFINITE

See Also:

• Constant Field Values

RING_DELAY_MILLIS

public static final int RING_DELAY_MILLIS

SCHEMA_DELAY_MILLIS

public static final int SCHEMA_DELAY_MILLIS

valueFactory

public volatile VersionedValue.VersionedValueFactory valueFactory

snapshotManager

public final SnapshotManager snapshotManager

instance

public static final StorageService instance

skipNotificationListeners

public volatile boolean skipNotificationListeners

nextRepairCommand

public static final AtomicInteger nextRepairCommand

useStrictConsistency

public static final boolean useStrictConsistency

sstablesTracker

public final SSTablesGlobalTracker sstablesTracker

Constructor Details

StorageService

public StorageService()

Method Details

getOutOfRangeOperationCounts

public Map<String,long[]> getOutOfRangeOperationCounts()

Description copied from interface: StorageServiceMBean

Get the per-keyspace counts of operations that the node has received for tokens outside its owned ranges. Represented as a Map<String, long[]>, keys are keyspace names and the values are the counts for read, write and paxos ops respectivly. e.g. keyspace_name -> [reads, writes, paxos].

Specified by:

getOutOfRangeOperationCounts in interface StorageServiceMBean

incOutOfRangeOperationCount

public void incOutOfRangeOperationCount()

isInShutdownHook

@Deprecated(since="3.10")
public boolean isInShutdownHook()

Deprecated.

See CASSANDRA-12509

isShutdown

public boolean isShutdown()

setIsShutdownUnsafeForTests

public void setIsShutdownUnsafeForTests(boolean isShutdown)

for in-jvm dtest use - forces isShutdown to be set to whatever passed in.

getLocalReplicas

public RangesAtEndpoint getLocalReplicas(String keyspaceName)

getReplicas

public RangesAtEndpoint getReplicas(String keyspaceName,
 InetAddressAndPort endpoint)

getReplicas

public RangesAtEndpoint getReplicas(AbstractReplicationStrategy replicationStrategy,
 InetAddressAndPort endpoint)

getLocalRanges

public List<Range<Token>> getLocalRanges(String ks)

getLocalAndPendingRanges

public List<Range<Token>> getLocalAndPendingRanges(String ks)

getNormalizedRanges

public OwnedRanges getNormalizedRanges(String keyspaceName,
 InetAddressAndPort ep)

getNormalizedLocalRanges

public OwnedRanges getNormalizedLocalRanges(String keyspaceName)

getPrimaryRanges

public Collection<Range<Token>> getPrimaryRanges(String keyspace)

getPrimaryRangesWithinDC

public Collection<Range<Token>> getPrimaryRangesWithinDC(String keyspace)

isSurveyMode

public boolean isSurveyMode()

hasJoined

public boolean hasJoined()

setTokens

public void setTokens(Collection<Token> tokens)

This method updates the local token on disk

setGossipTokens

public void setGossipTokens(Collection<Token> tokens)

registerDaemon

public void registerDaemon(CassandraDaemon daemon)

register

public void register(IEndpointLifecycleSubscriber subscriber)

unregister

public void unregister(IEndpointLifecycleSubscriber subscriber)

stopGossiping

public void stopGossiping()

Specified by:

stopGossiping in interface StorageServiceMBean

startGossiping

public void startGossiping()

Specified by:

startGossiping in interface StorageServiceMBean

isGossipRunning

public boolean isGossipRunning()

Specified by:

isGossipRunning in interface StorageServiceMBean

startNativeTransport

public void startNativeTransport()

Specified by:

startNativeTransport in interface StorageServiceMBean

stopNativeTransport

public void stopNativeTransport(boolean force)

Specified by:

stopNativeTransport in interface StorageServiceMBean

isNativeTransportRunning

public boolean isNativeTransportRunning()

Specified by:

isNativeTransportRunning in interface StorageServiceMBean

enableNativeTransportOldProtocolVersions

public void enableNativeTransportOldProtocolVersions()

Specified by:

enableNativeTransportOldProtocolVersions in interface StorageServiceMBean

disableNativeTransportOldProtocolVersions

public void disableNativeTransportOldProtocolVersions()

Specified by:

disableNativeTransportOldProtocolVersions in interface StorageServiceMBean

stopTransports

public void stopTransports()

stopClient

public void stopClient()

isInitialized

public boolean isInitialized()

Specified by:

isInitialized in interface StorageServiceMBean

isGossipActive

public boolean isGossipActive()

isDaemonSetupCompleted

public boolean isDaemonSetupCompleted()

stopDaemon

public void stopDaemon()

Specified by:

stopDaemon in interface StorageServiceMBean

checkForEndpointCollision

public void checkForEndpointCollision(UUID localHostId,
 Set<InetAddressAndPort> peers)
                               throws ConfigurationException

Throws:

ConfigurationException

unsafeInitialize

public void unsafeInitialize()
                      throws ConfigurationException

Throws:

ConfigurationException

initServer

public void initServer()
                throws ConfigurationException

Throws:

ConfigurationException

initServer

public void initServer(int schemaAndRingDelayMillis)
                throws ConfigurationException

Throws:

ConfigurationException

initServer

public void initServer(int schemaTimeoutMillis,
 int ringTimeoutMillis)
                throws ConfigurationException

Throws:

ConfigurationException

completeInitialization

public void completeInitialization()

populateTokenMetadata

public void populateTokenMetadata()

isReplacing

public boolean isReplacing()

removeShutdownHook

public void removeShutdownHook()

In the event of forceful termination we need to remove the shutdown hook to prevent hanging (OOM for instance)

isSeed

public static boolean isSeed()

startSnapshotManager

public void startSnapshotManager()

waitForSchema

public void waitForSchema(long schemaTimeoutMillis,
 long ringTimeoutMillis)

joinTokenRing

public void joinTokenRing(boolean finishJoiningRing,
 boolean shouldBootstrap,
 long schemaTimeoutMillis,
 long bootstrapTimeoutMillis,
 long ringTimeoutMillis)
                   throws ConfigurationException

Throws:

ConfigurationException

isReplacingSameAddress

public static boolean isReplacingSameAddress()

gossipSnitchInfo

public void gossipSnitchInfo()

joinRing

public void joinRing()
              throws IOException

Specified by:

joinRing in interface StorageServiceMBean

Throws:

IOException

finishJoiningRing

public void finishJoiningRing(boolean didBootstrap,
 Collection<Token> tokens)

doAuthSetup

public void doAuthSetup(boolean setUpSchema)

doAutoRepairSetup

public void doAutoRepairSetup()

isAuthSetupComplete

public boolean isAuthSetupComplete()

authSetupCalled

public boolean authSetupCalled()

setUpDistributedSystemKeyspaces

public void setUpDistributedSystemKeyspaces()

isJoined

public boolean isJoined()

Specified by:

isJoined in interface StorageServiceMBean

rebuild

public void rebuild(String sourceDc)

Description copied from interface: StorageServiceMBean

Initiate a process of streaming data for which we are responsible from other nodes. It is similar to bootstrap except meant to be used on a node which is already in the cluster (typically containing no data) as an alternative to running repair.

Specified by:

rebuild in interface StorageServiceMBean

Parameters:

sourceDc - Name of DC from which to select sources for streaming or null to pick any node

rebuild

public void rebuild(String sourceDc,
 String keyspace,
 String tokens,
 String specificSources)

Description copied from interface: StorageServiceMBean

Same as StorageServiceMBean.rebuild(String), but only for specified keyspace and ranges.

Specified by:

rebuild in interface StorageServiceMBean

Parameters:

sourceDc - Name of DC from which to select sources for streaming or null to pick any node

keyspace - Name of the keyspace which to rebuild or null to rebuild all keyspaces.

tokens - Range of tokens to rebuild or null to rebuild all token ranges. In the format of: "(start_token_1,end_token_1],(start_token_2,end_token_2],...(start_token_n,end_token_n]"

specificSources - list of sources that can be used for rebuilding. Must be other nodes in the cluster. The format of the string is comma separated values.

rebuild

public void rebuild(String sourceDc,
 String keyspace,
 String tokens,
 String specificSources,
 boolean excludeLocalDatacenterNodes)

Description copied from interface: StorageServiceMBean

Same as StorageServiceMBean.rebuild(String), but only for specified keyspace and ranges. It excludes local data center nodes

Specified by:

rebuild in interface StorageServiceMBean

Parameters:

sourceDc - Name of DC from which to select sources for streaming or null to pick any node

keyspace - Name of the keyspace which to rebuild or null to rebuild all keyspaces.

tokens - Range of tokens to rebuild or null to rebuild all token ranges. In the format of: "(start_token_1,end_token_1],(start_token_2,end_token_2],...(start_token_n,end_token_n]"

specificSources - list of sources that can be used for rebuilding. Mostly other nodes in the cluster.

excludeLocalDatacenterNodes - Flag to indicate whether local data center nodes should be excluded as sources for streaming.

setRpcTimeout

public void setRpcTimeout(long value)

Specified by:

setRpcTimeout in interface StorageServiceMBean

getRpcTimeout

public long getRpcTimeout()

Specified by:

getRpcTimeout in interface StorageServiceMBean

setReadRpcTimeout

public void setReadRpcTimeout(long value)

Specified by:

setReadRpcTimeout in interface StorageServiceMBean

getReadRpcTimeout

public long getReadRpcTimeout()

Specified by:

getReadRpcTimeout in interface StorageServiceMBean

setRangeRpcTimeout

public void setRangeRpcTimeout(long value)

Specified by:

setRangeRpcTimeout in interface StorageServiceMBean

getRangeRpcTimeout

public long getRangeRpcTimeout()

Specified by:

getRangeRpcTimeout in interface StorageServiceMBean

setWriteRpcTimeout

public void setWriteRpcTimeout(long value)

Specified by:

setWriteRpcTimeout in interface StorageServiceMBean

getWriteRpcTimeout

public long getWriteRpcTimeout()

Specified by:

getWriteRpcTimeout in interface StorageServiceMBean

setInternodeTcpConnectTimeoutInMS

public void setInternodeTcpConnectTimeoutInMS(int value)

Specified by:

setInternodeTcpConnectTimeoutInMS in interface StorageServiceMBean

getInternodeTcpConnectTimeoutInMS

public int getInternodeTcpConnectTimeoutInMS()

Specified by:

getInternodeTcpConnectTimeoutInMS in interface StorageServiceMBean

setInternodeTcpUserTimeoutInMS

public void setInternodeTcpUserTimeoutInMS(int value)

Specified by:

setInternodeTcpUserTimeoutInMS in interface StorageServiceMBean

getInternodeTcpUserTimeoutInMS

public int getInternodeTcpUserTimeoutInMS()

Specified by:

getInternodeTcpUserTimeoutInMS in interface StorageServiceMBean

setInternodeStreamingTcpUserTimeoutInMS

public void setInternodeStreamingTcpUserTimeoutInMS(int value)

Specified by:

setInternodeStreamingTcpUserTimeoutInMS in interface StorageServiceMBean

getInternodeStreamingTcpUserTimeoutInMS

public int getInternodeStreamingTcpUserTimeoutInMS()

Specified by:

getInternodeStreamingTcpUserTimeoutInMS in interface StorageServiceMBean

setCounterWriteRpcTimeout

public void setCounterWriteRpcTimeout(long value)

Specified by:

setCounterWriteRpcTimeout in interface StorageServiceMBean

getCounterWriteRpcTimeout

public long getCounterWriteRpcTimeout()

Specified by:

getCounterWriteRpcTimeout in interface StorageServiceMBean

setCasContentionTimeout

public void setCasContentionTimeout(long value)

Specified by:

setCasContentionTimeout in interface StorageServiceMBean

getCasContentionTimeout

public long getCasContentionTimeout()

Specified by:

getCasContentionTimeout in interface StorageServiceMBean

setTruncateRpcTimeout

public void setTruncateRpcTimeout(long value)

Specified by:

setTruncateRpcTimeout in interface StorageServiceMBean

getTruncateRpcTimeout

public long getTruncateRpcTimeout()

Specified by:

getTruncateRpcTimeout in interface StorageServiceMBean

setStreamThroughputMbPerSec

@Deprecated(since="4.1")
public void setStreamThroughputMbPerSec(int value)

Deprecated.

See CASSANDRA-15234

Specified by:

setStreamThroughputMbPerSec in interface StorageServiceMBean

setStreamThroughputMbitPerSec

public void setStreamThroughputMbitPerSec(int value)

Specified by:

setStreamThroughputMbitPerSec in interface StorageServiceMBean

setStreamThroughputMebibytesPerSec

public void setStreamThroughputMebibytesPerSec(int value)

Specified by:

setStreamThroughputMebibytesPerSec in interface StorageServiceMBean

getStreamThroughputMebibytesPerSecAsDouble

public double getStreamThroughputMebibytesPerSecAsDouble()

Specified by:

getStreamThroughputMebibytesPerSecAsDouble in interface StorageServiceMBean

getStreamThroughputMebibytesPerSec

public int getStreamThroughputMebibytesPerSec()

Description copied from interface: StorageServiceMBean

Below method returns stream_throughput_outbound rounded, for precise number, please, use getStreamThroughputMebibytesPerSecAsDouble

Specified by:

getStreamThroughputMebibytesPerSec in interface StorageServiceMBean

Returns:

stream_throughput_outbound in MiB

getStreamThroughputMbPerSec

@Deprecated(since="4.1")
public int getStreamThroughputMbPerSec()

Deprecated.

See CASSANDRA-15234

Specified by:

getStreamThroughputMbPerSec in interface StorageServiceMBean

Returns:

stream_throughput_outbound in MiB

getStreamThroughputMbitPerSec

@Deprecated(since="4.1")
public int getStreamThroughputMbitPerSec()

Deprecated.

See CASSANDRA-17225

Specified by:

getStreamThroughputMbitPerSec in interface StorageServiceMBean

Returns:

stream_throughput_outbound in megabits

getStreamThroughputMbitPerSecAsDouble

public double getStreamThroughputMbitPerSecAsDouble()

Specified by:

getStreamThroughputMbitPerSecAsDouble in interface StorageServiceMBean

setEntireSSTableStreamThroughputMebibytesPerSec

public void setEntireSSTableStreamThroughputMebibytesPerSec(int value)

Specified by:

setEntireSSTableStreamThroughputMebibytesPerSec in interface StorageServiceMBean

getEntireSSTableStreamThroughputMebibytesPerSecAsDouble

public double getEntireSSTableStreamThroughputMebibytesPerSecAsDouble()

Specified by:

getEntireSSTableStreamThroughputMebibytesPerSecAsDouble in interface StorageServiceMBean

setInterDCStreamThroughputMbPerSec

@Deprecated(since="4.1")
public void setInterDCStreamThroughputMbPerSec(int value)

Deprecated.

See CASSANDRA-15234

Specified by:

setInterDCStreamThroughputMbPerSec in interface StorageServiceMBean

setInterDCStreamThroughputMbitPerSec

public void setInterDCStreamThroughputMbitPerSec(int value)

Specified by:

setInterDCStreamThroughputMbitPerSec in interface StorageServiceMBean

getInterDCStreamThroughputMbPerSec

@Deprecated(since="4.1")
public int getInterDCStreamThroughputMbPerSec()

Deprecated.

See CASSANDRA-15234

Specified by:

getInterDCStreamThroughputMbPerSec in interface StorageServiceMBean

Returns:

inter_dc_stream_throughput_outbound in MiB

getInterDCStreamThroughputMbitPerSec

@Deprecated(since="4.1")
public int getInterDCStreamThroughputMbitPerSec()

Deprecated.

See CASSANDRA-17225

Specified by:

getInterDCStreamThroughputMbitPerSec in interface StorageServiceMBean

Returns:

inter_dc_stream_throughput_outbound in megabits

getInterDCStreamThroughputMbitPerSecAsDouble

public double getInterDCStreamThroughputMbitPerSecAsDouble()

Specified by:

getInterDCStreamThroughputMbitPerSecAsDouble in interface StorageServiceMBean

setInterDCStreamThroughputMebibytesPerSec

public void setInterDCStreamThroughputMebibytesPerSec(int value)

Specified by:

setInterDCStreamThroughputMebibytesPerSec in interface StorageServiceMBean

getInterDCStreamThroughputMebibytesPerSec

public int getInterDCStreamThroughputMebibytesPerSec()

Description copied from interface: StorageServiceMBean

Below method returns Inter_dc_stream_throughput_outbound rounded, for precise number, please, use getInterDCStreamThroughputMebibytesPerSecAsDouble

Specified by:

getInterDCStreamThroughputMebibytesPerSec in interface StorageServiceMBean

Returns:

inter_dc_stream_throughput_outbound in MiB

getInterDCStreamThroughputMebibytesPerSecAsDouble

public double getInterDCStreamThroughputMebibytesPerSecAsDouble()

Specified by:

getInterDCStreamThroughputMebibytesPerSecAsDouble in interface StorageServiceMBean

setEntireSSTableInterDCStreamThroughputMebibytesPerSec

public void setEntireSSTableInterDCStreamThroughputMebibytesPerSec(int value)

Specified by:

setEntireSSTableInterDCStreamThroughputMebibytesPerSec in interface StorageServiceMBean

getEntireSSTableInterDCStreamThroughputMebibytesPerSecAsDouble

public double getEntireSSTableInterDCStreamThroughputMebibytesPerSecAsDouble()

Specified by:

getEntireSSTableInterDCStreamThroughputMebibytesPerSecAsDouble in interface StorageServiceMBean

getCompactionThroughtputMibPerSecAsDouble

public double getCompactionThroughtputMibPerSecAsDouble()

Specified by:

getCompactionThroughtputMibPerSecAsDouble in interface StorageServiceMBean

getCompactionThroughtputBytesPerSec

public long getCompactionThroughtputBytesPerSec()

Specified by:

getCompactionThroughtputBytesPerSec in interface StorageServiceMBean

getCompactionThroughputMbPerSec

@Deprecated(since="4.1")
public int getCompactionThroughputMbPerSec()

Deprecated.

See CASSANDRA-17225

Specified by:

getCompactionThroughputMbPerSec in interface StorageServiceMBean

Returns:

compaction_throughgput in MiB

setCompactionThroughputMbPerSec

public void setCompactionThroughputMbPerSec(int value)

Specified by:

setCompactionThroughputMbPerSec in interface StorageServiceMBean

getCompressedReadAheadBufferInKB

public int getCompressedReadAheadBufferInKB()

Specified by:

getCompressedReadAheadBufferInKB in interface StorageServiceMBean

setCompressedReadAheadBufferInKB

public void setCompressedReadAheadBufferInKB(int sizeInKb)

Specified by:

setCompressedReadAheadBufferInKB in interface StorageServiceMBean

getBatchlogReplayThrottleInKB

public int getBatchlogReplayThrottleInKB()

Specified by:

getBatchlogReplayThrottleInKB in interface StorageServiceMBean

setBatchlogReplayThrottleInKB

public void setBatchlogReplayThrottleInKB(int throttleInKB)

Specified by:

setBatchlogReplayThrottleInKB in interface StorageServiceMBean

getConcurrentCompactors

public int getConcurrentCompactors()

Specified by:

getConcurrentCompactors in interface StorageServiceMBean

setConcurrentCompactors

public void setConcurrentCompactors(int value)

Specified by:

setConcurrentCompactors in interface StorageServiceMBean

bypassConcurrentValidatorsLimit

public void bypassConcurrentValidatorsLimit()

Specified by:

bypassConcurrentValidatorsLimit in interface StorageServiceMBean

enforceConcurrentValidatorsLimit

public void enforceConcurrentValidatorsLimit()

Specified by:

enforceConcurrentValidatorsLimit in interface StorageServiceMBean

isConcurrentValidatorsLimitEnforced

public boolean isConcurrentValidatorsLimitEnforced()

Specified by:

isConcurrentValidatorsLimitEnforced in interface StorageServiceMBean

getConcurrentIndexBuilders

public int getConcurrentIndexBuilders()

Specified by:

getConcurrentIndexBuilders in interface StorageServiceMBean

setConcurrentIndexBuilders

public void setConcurrentIndexBuilders(int value)

Specified by:

setConcurrentIndexBuilders in interface StorageServiceMBean

getConcurrentValidators

public int getConcurrentValidators()

Specified by:

getConcurrentValidators in interface StorageServiceMBean

setConcurrentValidators

public void setConcurrentValidators(int value)

Specified by:

setConcurrentValidators in interface StorageServiceMBean

getConcurrentViewBuilders

public int getConcurrentViewBuilders()

Specified by:

getConcurrentViewBuilders in interface StorageServiceMBean

setConcurrentViewBuilders

public void setConcurrentViewBuilders(int value)

Specified by:

setConcurrentViewBuilders in interface StorageServiceMBean

isIncrementalBackupsEnabled

public boolean isIncrementalBackupsEnabled()

Specified by:

isIncrementalBackupsEnabled in interface StorageServiceMBean

setIncrementalBackupsEnabled

public void setIncrementalBackupsEnabled(boolean value)

Specified by:

setIncrementalBackupsEnabled in interface StorageServiceMBean

setMovingModeUnsafe

public void setMovingModeUnsafe()

setNormalModeUnsafe

public void setNormalModeUnsafe()

Only used in jvm dtest when not using GOSSIP. See org.apache.cassandra.distributed.impl.Instance#startup(org.apache.cassandra.distributed.api.ICluster)

setStartingModeUnsafe

public void setStartingModeUnsafe()

prepareForBootstrap

public Collection<InetAddressAndPort> prepareForBootstrap(long schemaTimeoutMillis,
 long ringTimeoutMillis)

bootstrap

public boolean bootstrap(Collection<Token> tokens,
 long bootstrapTimeoutMillis)

Bootstrap node by fetching data from other nodes. If node is bootstrapping as a new node, then this also announces bootstrapping to the cluster. This blocks until streaming is done.

Parameters:

tokens - bootstrapping tokens

Returns:

true if bootstrap succeeds.

startBootstrap

public Future<StreamState> startBootstrap(Collection<Token> tokens)

startBootstrap

public Future<StreamState> startBootstrap(Collection<Token> tokens,
 boolean replacing)

getBootstrapState

public String getBootstrapState()

Specified by:

getBootstrapState in interface StorageServiceMBean

resumeBootstrap

public boolean resumeBootstrap()

Description copied from interface: StorageServiceMBean

Resume bootstrap streaming when there is failed data streaming.

Specified by:

resumeBootstrap in interface StorageServiceMBean

Returns:

true if the node successfully starts resuming. (this does not mean bootstrap streaming was success.)

getConcurrency

public Map<String,List<Integer>> getConcurrency(List<String> stageNames)

Specified by:

getConcurrency in interface StorageServiceMBean

setConcurrency

public void setConcurrency(String threadPoolName,
 int newCorePoolSize,
 int newMaximumPoolSize)

Description copied from interface: StorageServiceMBean

Sets the concurrency setting for processing stages

Specified by:

setConcurrency in interface StorageServiceMBean

isBootstrapMode

public boolean isBootstrapMode()

Description copied from interface: StorageServiceMBean

Check if currently bootstrapping. Note this becomes false before SystemKeyspace.bootstrapComplete() is called, as setting bootstrap to complete is called only when the node joins the ring.

Specified by:

isBootstrapMode in interface StorageServiceMBean

Returns:

True prior to bootstrap streaming completing. False prior to start of bootstrap and post streaming.

getTokenMetadata

public TokenMetadata getTokenMetadata()

getRangeToEndpointMap

public Map<List<String>,List<String>> getRangeToEndpointMap(String keyspace)

Description copied from interface: StorageServiceMBean

Retrieve a map of range to end points that describe the ring topology of a Cassandra cluster.

Specified by:

getRangeToEndpointMap in interface StorageServiceMBean

Returns:

mapping of ranges to end points

getRangeToEndpointWithPortMap

public Map<List<String>,List<String>> getRangeToEndpointWithPortMap(String keyspace)

Specified by:

getRangeToEndpointWithPortMap in interface StorageServiceMBean

getRangeToEndpointMap

public Map<List<String>,List<String>> getRangeToEndpointMap(String keyspace,
 boolean withPort)

for a keyspace, return the ranges and corresponding listen addresses.

Parameters:

keyspace -

Returns:

the endpoint map

getNativeaddress

public String getNativeaddress(InetAddressAndPort endpoint,
 boolean withPort)

Return the native address associated with an endpoint as a string.

Parameters:

endpoint - The endpoint to get rpc address for

Returns:

the native address

getRangeToRpcaddressMap

public Map<List<String>,List<String>> getRangeToRpcaddressMap(String keyspace)

Description copied from interface: StorageServiceMBean

Retrieve a map of range to rpc addresses that describe the ring topology of a Cassandra cluster.

Specified by:

getRangeToRpcaddressMap in interface StorageServiceMBean

Returns:

mapping of ranges to rpc addresses

getRangeToNativeaddressWithPortMap

public Map<List<String>,List<String>> getRangeToNativeaddressWithPortMap(String keyspace)

Specified by:

getRangeToNativeaddressWithPortMap in interface StorageServiceMBean

getPendingRangeToEndpointMap

public Map<List<String>,List<String>> getPendingRangeToEndpointMap(String keyspace)

Description copied from interface: StorageServiceMBean

Retrieve a map of pending ranges to endpoints that describe the ring topology

Specified by:

getPendingRangeToEndpointMap in interface StorageServiceMBean

Parameters:

keyspace - the keyspace to get the pending range map for.

Returns:

a map of pending ranges to endpoints

getPendingRangeToEndpointWithPortMap

public Map<List<String>,List<String>> getPendingRangeToEndpointWithPortMap(String keyspace)

Specified by:

getPendingRangeToEndpointWithPortMap in interface StorageServiceMBean

getRangeToAddressMap

public EndpointsByRange getRangeToAddressMap(String keyspace)

getRangeToAddressMapInLocalDC

public EndpointsByRange getRangeToAddressMapInLocalDC(String keyspace)

describeRingJMX

public List<String> describeRingJMX(String keyspace)
                             throws IOException

Description copied from interface: StorageServiceMBean

The same as describeRing(String) but converts TokenRange to the String for JMX compatibility

Specified by:

describeRingJMX in interface StorageServiceMBean

Parameters:

keyspace - The keyspace to fetch information about

Returns:

a List of TokenRange(s) converted to String for the given keyspace

Throws:

IOException

describeRingWithPortJMX

public List<String> describeRingWithPortJMX(String keyspace)
                                     throws IOException

Specified by:

describeRingWithPortJMX in interface StorageServiceMBean

Throws:

IOException

describeRing

public List<TokenRange> describeRing(String keyspace)
                              throws InvalidRequestException

The TokenRange for a given keyspace.

Parameters:

keyspace - The keyspace to fetch information about

Returns:

a List of TokenRange(s) for the given keyspace

Throws:

InvalidRequestException - if there is no ring information available about keyspace

describeLocalRing

public List<TokenRange> describeLocalRing(String keyspace)
                                   throws InvalidRequestException

The same as describeRing(String) but considers only the part of the ring formed by nodes in the local DC.

Throws:

InvalidRequestException

getTokenToEndpointMap

public Map<String,String> getTokenToEndpointMap()

Description copied from interface: StorageServiceMBean

Retrieve a map of tokens to endpoints, including the bootstrapping ones.

Specified by:

getTokenToEndpointMap in interface StorageServiceMBean

Returns:

a map of tokens to endpoints in ascending order

getTokenToEndpointWithPortMap

public Map<String,String> getTokenToEndpointWithPortMap()

Specified by:

getTokenToEndpointWithPortMap in interface StorageServiceMBean

getLocalHostId

public String getLocalHostId()

Description copied from interface: StorageServiceMBean

Retrieve this hosts unique ID

Specified by:

getLocalHostId in interface StorageServiceMBean

getLocalHostUUID

public UUID getLocalHostUUID()

getHostIdMap

public Map<String,String> getHostIdMap()

getEndpointToHostId

public Map<String,String> getEndpointToHostId()

Description copied from interface: StorageServiceMBean

Retrieve the mapping of endpoint to host ID.

Specified by:

getEndpointToHostId in interface StorageServiceMBean

getEndpointWithPortToHostId

public Map<String,String> getEndpointWithPortToHostId()

Specified by:

getEndpointWithPortToHostId in interface StorageServiceMBean

getHostIdToEndpoint

public Map<String,String> getHostIdToEndpoint()

Description copied from interface: StorageServiceMBean

Retrieve the mapping of host ID to endpoint.

Specified by:

getHostIdToEndpoint in interface StorageServiceMBean

getHostIdToEndpointWithPort

public Map<String,String> getHostIdToEndpointWithPort()

Specified by:

getHostIdToEndpointWithPort in interface StorageServiceMBean

beforeChange

public void beforeChange(InetAddressAndPort endpoint,
 EndpointState currentState,
 ApplicationState newStateKey,
 VersionedValue newValue)

Specified by:

beforeChange in interface IEndpointStateChangeSubscriber

onChange

public void onChange(InetAddressAndPort endpoint,
 ApplicationState state,
 VersionedValue value)

Specified by:

onChange in interface IEndpointStateChangeSubscriber

updateTopology

public void updateTopology(InetAddressAndPort endpoint)

updateTopology

public void updateTopology()

isRpcReady

public boolean isRpcReady(InetAddressAndPort endpoint)

setRpcReady

public void setRpcReady(boolean value)

Set the RPC status. Because when draining a node we need to set the RPC status to not ready, and drain is called by the shutdown hook, it may be that value is false and there is no local endpoint state. In this case it's OK to just do nothing. Therefore, we assert that the local endpoint state is not null only when value is true.

Parameters:

value - - true indicates that RPC is ready, false indicates the opposite.

getTokensFor

public Collection<Token> getTokensFor(InetAddressAndPort endpoint)

isReplacingSameHostAddressAndHostId

public boolean isReplacingSameHostAddressAndHostId(UUID hostId)

addExpireTimeIfFound

protected void addExpireTimeIfFound(InetAddressAndPort endpoint,
 long expireTime)

extractExpireTime

protected long extractExpireTime(String[] pieces)

onJoin

public void onJoin(InetAddressAndPort endpoint,
 EndpointState epState)

Description copied from interface: IEndpointStateChangeSubscriber

Use to inform interested parties about the change in the state for specified endpoint

Specified by:

onJoin in interface IEndpointStateChangeSubscriber

Parameters:

endpoint - endpoint for which the state change occurred.

epState - state that actually changed for the above endpoint.

onAlive

public void onAlive(InetAddressAndPort endpoint,
 EndpointState state)

Specified by:

onAlive in interface IEndpointStateChangeSubscriber

onRemove

public void onRemove(InetAddressAndPort endpoint)

Specified by:

onRemove in interface IEndpointStateChangeSubscriber

onDead

public void onDead(InetAddressAndPort endpoint,
 EndpointState state)

Specified by:

onDead in interface IEndpointStateChangeSubscriber

onRestart

public void onRestart(InetAddressAndPort endpoint,
 EndpointState state)

Description copied from interface: IEndpointStateChangeSubscriber

Called whenever a node is restarted. Note that there is no guarantee when that happens that the node was previously marked down. It will have only if state.isAlive() == false as state is from before the restarted node is marked up.

Specified by:

onRestart in interface IEndpointStateChangeSubscriber

getLoadString

public String getLoadString()

Description copied from interface: StorageServiceMBean

Human-readable load value

Specified by:

getLoadString in interface StorageServiceMBean

getUncompressedLoadString

public String getUncompressedLoadString()

Description copied from interface: StorageServiceMBean

Human-readable uncompressed load value

Specified by:

getUncompressedLoadString in interface StorageServiceMBean

getLoadMapWithPort

public Map<String,String> getLoadMapWithPort()

Specified by:

getLoadMapWithPort in interface StorageServiceMBean

getLoadMap

public Map<String,String> getLoadMap()

Description copied from interface: StorageServiceMBean

Human-readable load value. Keys are IP addresses.

Specified by:

getLoadMap in interface StorageServiceMBean

deliverHints

public final void deliverHints(String host)

Specified by:

deliverHints in interface StorageServiceMBean

getLocalTokens

public Collection<Token> getLocalTokens()

getEndpointForHostId

@Nullable
public InetAddressAndPort getEndpointForHostId(UUID hostId)

getHostIdForEndpoint

@Nullable
public UUID getHostIdForEndpoint(InetAddressAndPort address)

getTokens

public List<String> getTokens()

Description copied from interface: StorageServiceMBean

Fetch string representations of the tokens for this node.

Specified by:

getTokens in interface StorageServiceMBean

Returns:

a collection of tokens formatted as strings

getTokens

public List<String> getTokens(String endpoint)
                       throws UnknownHostException

Description copied from interface: StorageServiceMBean

Fetch string representations of the tokens for a specified node.

Specified by:

getTokens in interface StorageServiceMBean

Parameters:

endpoint - string representation of an node

Returns:

a collection of tokens formatted as strings

Throws:

UnknownHostException

getReleaseVersion

public String getReleaseVersion()

Description copied from interface: StorageServiceMBean

Fetch a string representation of the Cassandra version.

Specified by:

getReleaseVersion in interface StorageServiceMBean

Returns:

A string representation of the Cassandra version.

getGitSHA

public String getGitSHA()

Description copied from interface: StorageServiceMBean

Fetch a string representation of the Cassandra git SHA.

Specified by:

getGitSHA in interface StorageServiceMBean

Returns:

A string representation of the Cassandra git SHA.

getSchemaVersion

public String getSchemaVersion()

Description copied from interface: StorageServiceMBean

Fetch a string representation of the current Schema version.

Specified by:

getSchemaVersion in interface StorageServiceMBean

Returns:

A string representation of the Schema version.

getKeyspaceReplicationInfo

public String getKeyspaceReplicationInfo(String keyspaceName)

Description copied from interface: StorageServiceMBean

Fetch the replication factor for a given keyspace.

Specified by:

getKeyspaceReplicationInfo in interface StorageServiceMBean

Returns:

An integer that represents replication factor for the given keyspace.

getLeavingNodes

@Deprecated(since="4.0")
public List<String> getLeavingNodes()

Deprecated.

See CASSANDRA-7544

Description copied from interface: StorageServiceMBean

Retrieve the list of nodes currently leaving the ring.

Specified by:

getLeavingNodes in interface StorageServiceMBean

Returns:

set of IP addresses, as Strings

getLeavingNodesWithPort

public List<String> getLeavingNodesWithPort()

Specified by:

getLeavingNodesWithPort in interface StorageServiceMBean

getMovingNodes

@Deprecated(since="4.0")
public List<String> getMovingNodes()

Deprecated.

See CASSANDRA-7544

Description copied from interface: StorageServiceMBean

Retrieve the list of nodes currently moving in the ring.

Specified by:

getMovingNodes in interface StorageServiceMBean

Returns:

set of IP addresses, as Strings

getMovingNodesWithPort

public List<String> getMovingNodesWithPort()

Specified by:

getMovingNodesWithPort in interface StorageServiceMBean

getJoiningNodes

@Deprecated(since="4.0")
public List<String> getJoiningNodes()

Deprecated.

See CASSANDRA-7544

Description copied from interface: StorageServiceMBean

Retrieve the list of nodes currently bootstrapping into the ring.

Specified by:

getJoiningNodes in interface StorageServiceMBean

Returns:

set of IP addresses, as Strings

getJoiningNodesWithPort

public List<String> getJoiningNodesWithPort()

Specified by:

getJoiningNodesWithPort in interface StorageServiceMBean

getLiveNodes

@Deprecated(since="4.0")
public List<String> getLiveNodes()

Deprecated.

See CASSANDRA-7544

Description copied from interface: StorageServiceMBean

Retrieve the list of live nodes in the cluster, where "liveness" is determined by the failure detector of the node being queried.

Specified by:

getLiveNodes in interface StorageServiceMBean

Returns:

set of IP addresses, as Strings

getLiveNodesWithPort

public List<String> getLiveNodesWithPort()

Specified by:

getLiveNodesWithPort in interface StorageServiceMBean

getLiveRingMembers

public Set<InetAddressAndPort> getLiveRingMembers()

getLiveRingMembers

public Set<InetAddressAndPort> getLiveRingMembers(boolean excludeDeadStates)

getUnreachableNodes

@Deprecated(since="4.0")
public List<String> getUnreachableNodes()

Deprecated.

See CASSANDRA-7544

Description copied from interface: StorageServiceMBean

Retrieve the list of unreachable nodes in the cluster, as determined by this node's failure detector.

Specified by:

getUnreachableNodes in interface StorageServiceMBean

Returns:

set of IP addresses, as Strings

getUnreachableNodesWithPort

public List<String> getUnreachableNodesWithPort()

Specified by:

getUnreachableNodesWithPort in interface StorageServiceMBean

getAllDataFileLocations

public String[] getAllDataFileLocations()

Description copied from interface: StorageServiceMBean

Get the list of all data file locations from conf

Specified by:

getAllDataFileLocations in interface StorageServiceMBean

Returns:

String array of all locations

getLocalSystemKeyspacesDataFileLocations

public String[] getLocalSystemKeyspacesDataFileLocations()

Description copied from interface: StorageServiceMBean

Returns the locations where the local system keyspaces data should be stored.

Specified by:

getLocalSystemKeyspacesDataFileLocations in interface StorageServiceMBean

Returns:

the locations where the local system keyspaces data should be stored

getNonLocalSystemKeyspacesDataFileLocations

public String[] getNonLocalSystemKeyspacesDataFileLocations()

Description copied from interface: StorageServiceMBean

Returns the locations where should be stored the non system keyspaces data.

Specified by:

getNonLocalSystemKeyspacesDataFileLocations in interface StorageServiceMBean

Returns:

the locations where should be stored the non system keyspaces data

getCommitLogLocation

public String getCommitLogLocation()

Description copied from interface: StorageServiceMBean

Get location of the commit log

Specified by:

getCommitLogLocation in interface StorageServiceMBean

Returns:

a string path

getSavedCachesLocation

public String getSavedCachesLocation()

Description copied from interface: StorageServiceMBean

Get location of the saved caches dir

Specified by:

getSavedCachesLocation in interface StorageServiceMBean

Returns:

a string path

getCurrentGenerationNumber

public int getCurrentGenerationNumber()

Description copied from interface: StorageServiceMBean

Return the generation value for this node.

Specified by:

getCurrentGenerationNumber in interface StorageServiceMBean

Returns:

generation number

forceKeyspaceCleanup

public int forceKeyspaceCleanup(String keyspaceName,
 String... tables)
                         throws IOException,
ExecutionException,
InterruptedException

Description copied from interface: StorageServiceMBean

Trigger a cleanup of keys on a single keyspace

Specified by:

forceKeyspaceCleanup in interface StorageServiceMBean

Throws:

IOException

ExecutionException

InterruptedException

forceKeyspaceCleanup

public int forceKeyspaceCleanup(int jobs,
 String keyspaceName,
 String... tableNames)
                         throws IOException,
ExecutionException,
InterruptedException

Specified by:

forceKeyspaceCleanup in interface StorageServiceMBean

Throws:

IOException

ExecutionException

InterruptedException

scrub

public int scrub(boolean disableSnapshot,
 boolean skipCorrupted,
 boolean checkData,
 boolean reinsertOverflowedTTL,
 int jobs,
 String keyspaceName,
 String... tableNames)
          throws IOException,
ExecutionException,
InterruptedException

Specified by:

scrub in interface StorageServiceMBean

Throws:

IOException

ExecutionException

InterruptedException

scrub

public int scrub(boolean disableSnapshot,
 IScrubber.Options options,
 int jobs,
 String keyspaceName,
 String... tableNames)
          throws IOException,
ExecutionException,
InterruptedException

Throws:

IOException

ExecutionException

InterruptedException

verify

@Deprecated(since="4.0")
public int verify(boolean extendedVerify,
 String keyspaceName,
 String... tableNames)
           throws IOException,
ExecutionException,
InterruptedException

Deprecated.

See CASSANDRA-14201

Description copied from interface: StorageServiceMBean

Verify (checksums of) the given keyspace. If tableNames array is empty, all CFs are verified. The entire sstable will be read to ensure each cell validates if extendedVerify is true

Specified by:

verify in interface StorageServiceMBean

Throws:

IOException

ExecutionException

InterruptedException

verify

public int verify(boolean extendedVerify,
 boolean checkVersion,
 boolean diskFailurePolicy,
 boolean mutateRepairStatus,
 boolean checkOwnsTokens,
 boolean quick,
 String keyspaceName,
 String... tableNames)
           throws IOException,
ExecutionException,
InterruptedException

Specified by:

verify in interface StorageServiceMBean

Throws:

IOException

ExecutionException

InterruptedException

upgradeSSTables

public int upgradeSSTables(String keyspaceName,
 boolean excludeCurrentVersion,
 String... tableNames)
                    throws IOException,
ExecutionException,
InterruptedException

Description copied from interface: StorageServiceMBean

Rewrite all sstables to the latest version. Unlike scrub, it doesn't skip bad rows and do not snapshot sstables first.

Specified by:

upgradeSSTables in interface StorageServiceMBean

Throws:

IOException

ExecutionException

InterruptedException

upgradeSSTables

public int upgradeSSTables(String keyspaceName,
 boolean skipIfCurrentVersion,
 long skipIfNewerThanTimestamp,
 int jobs,
 String... tableNames)
                    throws IOException,
ExecutionException,
InterruptedException

Specified by:

upgradeSSTables in interface StorageServiceMBean

Throws:

IOException

ExecutionException

InterruptedException

recompressSSTables

public int recompressSSTables(String keyspaceName,
 int jobs,
 String... tableNames)
                       throws IOException,
ExecutionException,
InterruptedException

Specified by:

recompressSSTables in interface StorageServiceMBean

Throws:

IOException

ExecutionException

InterruptedException

rewriteSSTables

public int rewriteSSTables(String keyspaceName,
 boolean skipIfCurrentVersion,
 long skipIfNewerThanTimestamp,
 boolean skipIfCompressionMatches,
 int jobs,
 String... tableNames)
                    throws IOException,
ExecutionException,
InterruptedException

Throws:

IOException

ExecutionException

InterruptedException

getPreparedStatements

public List<Pair<String,String>> getPreparedStatements()

dropPreparedStatements

public void dropPreparedStatements(boolean memoryOnly)

Specified by:

dropPreparedStatements in interface StorageServiceMBean

forceKeyspaceCompaction

public void forceKeyspaceCompaction(boolean splitOutput,
 String keyspaceName,
 String... tableNames)
                             throws IOException,
ExecutionException,
InterruptedException

Description copied from interface: StorageServiceMBean

Forces major compaction of a single keyspace

Specified by:

forceKeyspaceCompaction in interface StorageServiceMBean

Throws:

IOException

ExecutionException

InterruptedException

relocateSSTables

public int relocateSSTables(String keyspaceName,
 String... tableNames)
                     throws IOException,
ExecutionException,
InterruptedException

Specified by:

relocateSSTables in interface StorageServiceMBean

Throws:

IOException

ExecutionException

InterruptedException

relocateSSTables

public int relocateSSTables(int jobs,
 String keyspaceName,
 String... tableNames)
                     throws IOException,
ExecutionException,
InterruptedException

Specified by:

relocateSSTables in interface StorageServiceMBean

Throws:

IOException

ExecutionException

InterruptedException

garbageCollect

public int garbageCollect(String tombstoneOptionString,
 int jobs,
 String keyspaceName,
 String... tableNames)
                   throws IOException,
ExecutionException,
InterruptedException

Description copied from interface: StorageServiceMBean

Rewrites all sstables from the given tables to remove deleted data. The tombstone option defines the granularity of the procedure: ROW removes deleted partitions and rows, CELL also removes overwritten or deleted cells.

Specified by:

garbageCollect in interface StorageServiceMBean

Throws:

IOException

ExecutionException

InterruptedException

takeSnapshot

public void takeSnapshot(String tag,
 Map<String,String> options,
 String... entities)
                  throws IOException

Takes the snapshot of a multiple column family from different keyspaces. A snapshot name must be specified.

Specified by:

takeSnapshot in interface StorageServiceMBean

Parameters:

tag - the tag given to the snapshot; may not be null or empty

options - Map of options (skipFlush is the only supported option for now)

entities - list of keyspaces / tables in the form of empty | ks1 ks2 ... | ks1.cf1,ks2.cf2,...

Throws:

IOException

takeTableSnapshot

public void takeTableSnapshot(String keyspaceName,
 String tableName,
 String tag)
                       throws IOException

Takes the snapshot of a specific table. A snapshot name must be specified.

Specified by:

takeTableSnapshot in interface StorageServiceMBean

Parameters:

keyspaceName - the keyspace which holds the specified table

tableName - the table to snapshot

tag - the tag given to the snapshot; may not be null or empty

Throws:

IOException

forceKeyspaceCompactionForTokenRange

public void forceKeyspaceCompactionForTokenRange(String keyspaceName,
 String startToken,
 String endToken,
 String... tableNames)
                                          throws IOException,
ExecutionException,
InterruptedException

Description copied from interface: StorageServiceMBean

Forces major compaction of specified token range in a single keyspace.

Specified by:

forceKeyspaceCompactionForTokenRange in interface StorageServiceMBean

Parameters:

keyspaceName - the name of the keyspace to be compacted

startToken - the token at which the compaction range starts (inclusive)

endToken - the token at which compaction range ends (inclusive)

tableNames - the names of the tables to be compacted

Throws:

IOException

ExecutionException

InterruptedException

forceKeyspaceCompactionForPartitionKey

public void forceKeyspaceCompactionForPartitionKey(String keyspaceName,
 String partitionKey,
 String... tableNames)
                                            throws IOException,
ExecutionException,
InterruptedException

Description copied from interface: StorageServiceMBean

Forces major compactions for the range represented by the partition key

Specified by:

forceKeyspaceCompactionForPartitionKey in interface StorageServiceMBean

Throws:

IOException

ExecutionException

InterruptedException

forceCompactionKeysIgnoringGcGrace

public void forceCompactionKeysIgnoringGcGrace(String keyspaceName,
 String tableName,
 String... partitionKeysIgnoreGcGrace)
                                        throws IOException,
ExecutionException,
InterruptedException

Forces compaction for a list of partition keys in a table The method will ignore the gc_grace_seconds for the partitionKeysIgnoreGcGrace during the comapction, in order to purge the tombstones and free up space quicker.

Specified by:

forceCompactionKeysIgnoringGcGrace in interface StorageServiceMBean

Parameters:

keyspaceName - keyspace name

tableName - table name

partitionKeysIgnoreGcGrace - partition keys ignoring the gc_grace_seconds

Throws:

IOException - on any I/O operation error

ExecutionException - when attempting to retrieve the result of a task that aborted by throwing an exception

InterruptedException - when a thread is waiting, sleeping, or otherwise occupied, and the thread is interrupted, either before or during the activity

takeSnapshot

public void takeSnapshot(String tag,
 String... keyspaceNames)
                  throws IOException

Takes the snapshot for the given keyspaces. A snapshot name must be specified.

Specified by:

takeSnapshot in interface StorageServiceMBean

Parameters:

tag - the tag given to the snapshot; may not be null or empty

keyspaceNames - the names of the keyspaces to snapshot; empty means "all."

Throws:

IOException

takeMultipleTableSnapshot

public void takeMultipleTableSnapshot(String tag,
 String... tableList)
                               throws IOException

Takes the snapshot of a multiple column family from different keyspaces. A snapshot name must be specified.

Specified by:

takeMultipleTableSnapshot in interface StorageServiceMBean

Parameters:

tag - the tag given to the snapshot; may not be null or empty

tableList - list of tables from different keyspace in the form of ks1.cf1 ks2.cf2

Throws:

IOException

clearSnapshot

public void clearSnapshot(String tag,
 String... keyspaceNames)

Remove the snapshot with the given name from the given keyspaces. If no tag is specified we will remove all snapshots.

Specified by:

clearSnapshot in interface StorageServiceMBean

Parameters:

tag - name of snapshot to clear, if null or empty string, all snapshots of given keyspace will be cleared

keyspaceNames - name of keyspaces to clear snapshots for

clearSnapshot

public void clearSnapshot(Map<String,Object> options,
 String tag,
 String... keyspaceNames)

Description copied from interface: StorageServiceMBean

Remove the snapshot with the given name from the given keyspaces. If no tag is specified we will remove all snapshots.

Specified by:

clearSnapshot in interface StorageServiceMBean

Parameters:

options - map of options for cleanup operation, consult nodetool's ClearSnapshot

tag - name of snapshot to clear, if null or empty string, all snapshots of given keyspace will be cleared

keyspaceNames - name of keyspaces to clear snapshots for

getSnapshotDetails

public Map<String,TabularData> getSnapshotDetails(Map<String,String> options)

Description copied from interface: StorageServiceMBean

Get the details of all the snapshots

Specified by:

getSnapshotDetails in interface StorageServiceMBean

Parameters:

options - map of options used for filtering of snapshots

Returns:

A map of snapshotName to all its details in Tabular form.

getSnapshotDetails

@Deprecated(since="4.1")
public Map<String,TabularData> getSnapshotDetails()

Deprecated.

See CASSANDRA-16789

Description copied from interface: StorageServiceMBean

Get the details of all the snapshot

Specified by:

getSnapshotDetails in interface StorageServiceMBean

Returns:

A map of snapshotName to all its details in Tabular form.

trueSnapshotsSize

public long trueSnapshotsSize()

Description copied from interface: StorageServiceMBean

Get the true size taken by all snapshots across all keyspaces.

Specified by:

trueSnapshotsSize in interface StorageServiceMBean

Returns:

True size taken by all the snapshots.

setSnapshotLinksPerSecond

public void setSnapshotLinksPerSecond(long throttle)

Description copied from interface: StorageServiceMBean

Set the current hardlink-per-second throttle for snapshots A setting of zero indicates no throttling

Specified by:

setSnapshotLinksPerSecond in interface StorageServiceMBean

getSnapshotLinksPerSecond

public long getSnapshotLinksPerSecond()

Description copied from interface: StorageServiceMBean

Get the current hardlink-per-second throttle for snapshots A setting of zero indicates no throttling.

Specified by:

getSnapshotLinksPerSecond in interface StorageServiceMBean

Returns:

snapshot links-per-second throttle

refreshSizeEstimates

public void refreshSizeEstimates()
                          throws ExecutionException

Description copied from interface: StorageServiceMBean

Forces refresh of values stored in system.size_estimates of all column families.

Specified by:

refreshSizeEstimates in interface StorageServiceMBean

Throws:

ExecutionException

cleanupSizeEstimates

public void cleanupSizeEstimates()

Description copied from interface: StorageServiceMBean

Removes extraneous entries in system.size_estimates.

Specified by:

cleanupSizeEstimates in interface StorageServiceMBean

getValidColumnFamilies

public Iterable<ColumnFamilyStore> getValidColumnFamilies(boolean allowIndexes,
 boolean autoAddIndexes,
 String keyspaceName,
 String... cfNames)

Parameters:

allowIndexes - Allow index CF names to be passed in

autoAddIndexes - Automatically add secondary indexes if a CF has them

keyspaceName - keyspace

cfNames - CFs

Throws:

IllegalArgumentException - when given CF name does not exist

forceKeyspaceFlush

public void forceKeyspaceFlush(String keyspaceName,
 String... tableNames)
                        throws IOException

Flush all memtables for a keyspace and column families.

Specified by:

forceKeyspaceFlush in interface StorageServiceMBean

Parameters:

keyspaceName -

tableNames -

Throws:

IOException

forceKeyspaceFlush

public void forceKeyspaceFlush(String keyspaceName,
 ColumnFamilyStore.FlushReason reason)
                        throws IOException

Flush all memtables for a keyspace and column families.

Parameters:

keyspaceName -

Throws:

IOException

repairAsync

public int repairAsync(String keyspace,
 Map<String,String> repairSpec)

Description copied from interface: StorageServiceMBean

Invoke repair asynchronously. You can track repair progress by subscribing JMX notification sent from this StorageServiceMBean. Notification format is: type: "repair" userObject: int array of length 2, [0]=command number, [1]=ordinal of ActiveRepairService.Status

Specified by:

repairAsync in interface StorageServiceMBean

Parameters:

keyspace - Keyspace name to repair. Should not be null.

repairSpec - repair option.

Returns:

Repair command number, or 0 if nothing to repair

repair

public Pair<Integer,Future<?>> repair(String keyspace,
 Map<String,String> repairSpec,
 List<ProgressListener> listeners)

repair

public Pair<Integer,Future<?>> repair(String keyspace,
 RepairOption option,
 List<ProgressListener> listeners)

getTokenFactory

public Token.TokenFactory getTokenFactory()

startRepairPaxosForTopologyChange

public Future<?> startRepairPaxosForTopologyChange(String reason)

autoRepairPaxos

public Future<?> autoRepairPaxos(TableId tableId)

forceTerminateAllRepairSessions

public void forceTerminateAllRepairSessions()

Specified by:

forceTerminateAllRepairSessions in interface StorageServiceMBean

getParentRepairStatus

@Nullable
public List<String> getParentRepairStatus(int cmd)

Description copied from interface: StorageServiceMBean

Get the status of a given parent repair session.

Specified by:

getParentRepairStatus in interface StorageServiceMBean

Parameters:

cmd - the int reference returned when issuing the repair

Returns:

status of parent repair from enum ActiveRepairService.ParentRepairStatus followed by final message or messages of the session

setRepairSessionMaxTreeDepth

@Deprecated(since="5.0")
public void setRepairSessionMaxTreeDepth(int depth)

Deprecated.

See CASSANDRA-17668

Specified by:

setRepairSessionMaxTreeDepth in interface StorageServiceMBean

getRepairSessionMaxTreeDepth

@Deprecated(since="5.0")
public int getRepairSessionMaxTreeDepth()

Deprecated.

See CASSANDRA-17668

Specified by:

getRepairSessionMaxTreeDepth in interface StorageServiceMBean

setRepairSessionMaximumTreeDepth

public void setRepairSessionMaximumTreeDepth(int depth)

Specified by:

setRepairSessionMaximumTreeDepth in interface StorageServiceMBean

getRepairSessionMaximumTreeDepth

public int getRepairSessionMaximumTreeDepth()

Specified by:

getRepairSessionMaximumTreeDepth in interface StorageServiceMBean

getPrimaryRangesForEndpoint

public Collection<Range<Token>> getPrimaryRangesForEndpoint(String keyspace,
 InetAddressAndPort ep)

Get the "primary ranges" for the specified keyspace and endpoint. "Primary ranges" are the ranges that the node is responsible for storing replica primarily. The node that stores replica primarily is defined as the first node returned by AbstractReplicationStrategy.calculateNaturalReplicas(org.apache.cassandra.dht.Token, org.apache.cassandra.locator.TokenMetadata).

Parameters:

keyspace - Keyspace name to check primary ranges

ep - endpoint we are interested in.

Returns:

primary ranges for the specified endpoint.

getPrimaryRangeForEndpointWithinDC

public Collection<Range<Token>> getPrimaryRangeForEndpointWithinDC(String keyspace,
 InetAddressAndPort referenceEndpoint)

Get the "primary ranges" within local DC for the specified keyspace and endpoint.

Parameters:

keyspace - Keyspace name to check primary ranges

referenceEndpoint - endpoint we are interested in.

Returns:

primary ranges within local DC for the specified endpoint.

See Also:

• getPrimaryRangesForEndpoint(String, InetAddressAndPort)

getLocalPrimaryRange

public Collection<Range<Token>> getLocalPrimaryRange()

getLocalPrimaryRangeForEndpoint

public Collection<Range<Token>> getLocalPrimaryRangeForEndpoint(InetAddressAndPort referenceEndpoint)

getAllRanges

public List<Range<Token>> getAllRanges(List<Token> sortedTokens)

Get all ranges that span the ring given a set of tokens. All ranges are in sorted order of ranges.

Returns:

ranges in sorted order

getNaturalEndpoints

@Deprecated(since="4.0")
public List<InetAddress> getNaturalEndpoints(String keyspaceName,
 String cf,
 String key)

Deprecated.

See CASSANDRA-7544

This method returns the N endpoints that are responsible for storing the specified key i.e for replication.

Specified by:

getNaturalEndpoints in interface StorageServiceMBean

Parameters:

keyspaceName - keyspace name also known as keyspace

cf - Column family name

key - key for which we need to find the endpoint

Returns:

the endpoint responsible for this key

getNaturalEndpointsWithPort

public List<String> getNaturalEndpointsWithPort(String keyspaceName,
 String cf,
 String key)

Specified by:

getNaturalEndpointsWithPort in interface StorageServiceMBean

getNaturalEndpoints

@Deprecated(since="4.0")
public List<InetAddress> getNaturalEndpoints(String keyspaceName,
 ByteBuffer key)

Deprecated.

See CASSANDRA-7544

Specified by:

getNaturalEndpoints in interface StorageServiceMBean

getNaturalEndpointsWithPort

public List<String> getNaturalEndpointsWithPort(String keyspaceName,
 ByteBuffer key)

Specified by:

getNaturalEndpointsWithPort in interface StorageServiceMBean

getNaturalReplicasForToken

public EndpointsForToken getNaturalReplicasForToken(String keyspaceName,
 String cf,
 String key)

getNaturalReplicasForToken

public EndpointsForToken getNaturalReplicasForToken(String keyspaceName,
 ByteBuffer key)

getKeyFromPartition

public DecoratedKey getKeyFromPartition(String keyspaceName,
 String table,
 String partitionKey)

getToken

public String getToken(String keyspaceName,
 String table,
 String key)

Specified by:

getToken in interface StorageServiceMBean

isEndpointValidForWrite

public boolean isEndpointValidForWrite(String keyspace,
 Token token)

setLoggingLevel

public void setLoggingLevel(String classQualifier,
 String rawLevel)
                     throws Exception

Description copied from interface: StorageServiceMBean

set the logging level at runtime

If both classQualifer and level are empty/null, it will reload the configuration to reset.
If classQualifer is not empty but level is empty/null, it will set the level to null for the defined classQualifer
If level cannot be parsed, then the level will be defaulted to DEBUG

Specified by:

setLoggingLevel in interface StorageServiceMBean

Parameters:

classQualifier - The logger's classQualifer

rawLevel - The log level

Throws:

Exception

See Also:

• Level.toLevel(String)

getLoggingLevels

public Map<String,String> getLoggingLevels()

Description copied from interface: StorageServiceMBean

get the runtime logging levels

Specified by:

getLoggingLevels in interface StorageServiceMBean

Returns:

the runtime logging levels for all the configured loggers

getSplits

public List<Pair<Range<Token>,Long>> getSplits(String keyspaceName,
 String cfName,
 Range<Token> range,
 int keysPerSplit)

Returns:

list of Token ranges (_not_ keys!) together with estimated key count, breaking up the data this node is responsible for into pieces of roughly keysPerSplit

decommission

public void decommission(boolean force)
                  throws InterruptedException

Description copied from interface: StorageServiceMBean

transfer this node's data to other machines and remove it from service.

Specified by:

decommission in interface StorageServiceMBean

Parameters:

force - Decommission even if this will reduce N to be less than RF.

Throws:

InterruptedException

prepareUnbootstrapStreaming

public Supplier<Future<StreamState>> prepareUnbootstrapStreaming()

move

public void move(String newToken)
          throws IOException

Specified by:

move in interface StorageServiceMBean

Parameters:

newToken - token to move this node to. This node will unload its data onto its neighbors, and bootstrap to the new token.

Throws:

IOException

getRemovalStatus

public String getRemovalStatus()

Description copied from interface: StorageServiceMBean

Get the status of a token removal.

Specified by:

getRemovalStatus in interface StorageServiceMBean

getRemovalStatusWithPort

public String getRemovalStatusWithPort()

Specified by:

getRemovalStatusWithPort in interface StorageServiceMBean

forceRemoveCompletion

public void forceRemoveCompletion()

Force a remove operation to complete. This may be necessary if a remove operation blocks forever due to node/stream failure. removeNode() must be called first, this is a last resort measure. No further attempt will be made to restore replicas.

Specified by:

forceRemoveCompletion in interface StorageServiceMBean

removeNode

public void removeNode(String hostIdString)

Remove a node that has died, attempting to restore the replica count. If the node is alive, decommission should be attempted. If decommission fails, then removeNode should be called. If we fail while trying to restore the replica count, finally forceRemoveCompleteion should be called to forcibly remove the node without regard to replica count.

Specified by:

removeNode in interface StorageServiceMBean

Parameters:

hostIdString - Host ID for the node

confirmReplication

public void confirmReplication(InetAddressAndPort node)

getOperationMode

public String getOperationMode()

Description copied from interface: StorageServiceMBean

get the operational mode (leaving, joining, normal, decommissioned, client)

Specified by:

getOperationMode in interface StorageServiceMBean

isStarting

public boolean isStarting()

Description copied from interface: StorageServiceMBean

Returns whether the storage service is starting or not

Specified by:

isStarting in interface StorageServiceMBean

isMoving

public boolean isMoving()

isJoining

public boolean isJoining()

isDrained

public boolean isDrained()

Specified by:

isDrained in interface StorageServiceMBean

isDraining

public boolean isDraining()

Specified by:

isDraining in interface StorageServiceMBean

isNormal

public boolean isNormal()

isDecommissioned

public boolean isDecommissioned()

isDecommissionFailed

public boolean isDecommissionFailed()

Description copied from interface: StorageServiceMBean

Returns whether a node has failed to decommission. The fact that this method returns false does not mean that there was an attempt to decommission this node which was successful.

Specified by:

isDecommissionFailed in interface StorageServiceMBean

Returns:

true if decommission of this node has failed, false otherwise

isDecommissioning

public boolean isDecommissioning()

Description copied from interface: StorageServiceMBean

Returns whether a node is being decommissioned or not.

Specified by:

isDecommissioning in interface StorageServiceMBean

Returns:

true if this node is decommissioning, false otherwise

isBootstrapFailed

public boolean isBootstrapFailed()

Description copied from interface: StorageServiceMBean

Returns whether a node has failed to bootstrap. The fact that this method returns false does not mean that there was an attempt to bootstrap this node which was successful.

Specified by:

isBootstrapFailed in interface StorageServiceMBean

Returns:

true if bootstrap of this node has failed, false otherwise

getDrainProgress

public String getDrainProgress()

Description copied from interface: StorageServiceMBean

get the progress of a drain operation

Specified by:

getDrainProgress in interface StorageServiceMBean

drain

public void drain()
           throws IOException,
InterruptedException,
ExecutionException

Shuts node off to writes, empties memtables and the commit log.

Specified by:

drain in interface StorageServiceMBean

Throws:

IOException

InterruptedException

ExecutionException

drain

protected void drain(boolean isFinalShutdown)
              throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

disableAutoCompaction

public void disableAutoCompaction()

addPreShutdownHook

public boolean addPreShutdownHook(Runnable hook)

Add a runnable which will be called before shut down or drain. This is useful for other applications running in the same JVM which may want to shut down first rather than time out attempting to use Cassandra calls which will no longer work.

Parameters:

hook - the code to run

Returns:

true on success, false if Cassandra is already shutting down, in which case the runnable has NOT been added.

removePreShutdownHook

public boolean removePreShutdownHook(Runnable hook)

Remove a preshutdown hook

addPostShutdownHook

public boolean addPostShutdownHook(Runnable hook)

Add a runnable which will be called after shutdown or drain. This is useful for other applications running in the same JVM that Cassandra needs to work and should shut down later.

Parameters:

hook - the code to run

Returns:

true on success, false if Cassandra is already shutting down, in which case the runnable has NOT been added.

removePostShutdownHook

public boolean removePostShutdownHook(Runnable hook)

Remove a postshutdownhook

setPartitionerUnsafe

public IPartitioner setPartitionerUnsafe(IPartitioner newPartitioner)

truncate

public void truncate(String keyspace,
 String table)
              throws TimeoutException,
IOException

Description copied from interface: StorageServiceMBean

Truncates (deletes) the given table from the provided keyspace. Calling truncate results in actual deletion of all data in the cluster under the given table and it will fail unless all hosts are up. All data in the given column family will be deleted, but its definition will not be affected.

Specified by:

truncate in interface StorageServiceMBean

Parameters:

keyspace - The keyspace to delete from

table - The column family to delete data from.

Throws:

TimeoutException

IOException

getOwnership

public Map<InetAddress,Float> getOwnership()

Description copied from interface: StorageServiceMBean

given a list of tokens (representing the nodes in the cluster), returns a mapping from "token -> %age of cluster owned by that token"

Specified by:

getOwnership in interface StorageServiceMBean

getOwnershipWithPort

public Map<String,Float> getOwnershipWithPort()

Specified by:

getOwnershipWithPort in interface StorageServiceMBean

effectiveOwnership

public LinkedHashMap<InetAddress,Float> effectiveOwnership(String keyspace)
                                                    throws IllegalStateException

Description copied from interface: StorageServiceMBean

Effective ownership is % of the data each node owns given the keyspace we calculate the percentage using replication factor. If Keyspace == null, this method will try to verify if all the keyspaces in the cluster have the same replication strategies and if yes then we will use the first else a empty Map is returned.

Specified by:

effectiveOwnership in interface StorageServiceMBean

Throws:

IllegalStateException

effectiveOwnershipWithPort

public LinkedHashMap<String,Float> effectiveOwnershipWithPort(String keyspace)
                                                       throws IllegalStateException

Specified by:

effectiveOwnershipWithPort in interface StorageServiceMBean

Throws:

IllegalStateException

getKeyspaces

public List<String> getKeyspaces()

Specified by:

getKeyspaces in interface StorageServiceMBean

getNonSystemKeyspaces

public List<String> getNonSystemKeyspaces()

Specified by:

getNonSystemKeyspaces in interface StorageServiceMBean

getNonLocalStrategyKeyspaces

public List<String> getNonLocalStrategyKeyspaces()

Specified by:

getNonLocalStrategyKeyspaces in interface StorageServiceMBean

getViewBuildStatuses

public Map<String,String> getViewBuildStatuses(String keyspace,
 String view,
 boolean withPort)

getViewBuildStatuses

public Map<String,String> getViewBuildStatuses(String keyspace,
 String view)

Specified by:

getViewBuildStatuses in interface StorageServiceMBean

getViewBuildStatusesWithPort

public Map<String,String> getViewBuildStatusesWithPort(String keyspace,
 String view)

Specified by:

getViewBuildStatusesWithPort in interface StorageServiceMBean

setDynamicUpdateInterval

public void setDynamicUpdateInterval(int dynamicUpdateInterval)

Specified by:

setDynamicUpdateInterval in interface StorageServiceMBean

getDynamicUpdateInterval

public int getDynamicUpdateInterval()

Specified by:

getDynamicUpdateInterval in interface StorageServiceMBean

updateSnitch

public void updateSnitch(String epSnitchClassName,
 Boolean dynamic,
 Integer dynamicUpdateInterval,
 Integer dynamicResetInterval,
 Double dynamicBadnessThreshold)
                  throws ClassNotFoundException

Description copied from interface: StorageServiceMBean

Change endpointsnitch class and dynamic-ness (and dynamic attributes) at runtime. This method is used to change the snitch implementation and/or dynamic snitch parameters. If epSnitchClassName is specified, it will configure a new snitch instance and make it a 'dynamic snitch' if dynamic is specified and true. The parameters dynamicUpdateInterval, dynamicResetInterval and dynamicBadnessThreshold can be specified individually to update the parameters of the dynamic snitch during runtime.

Specified by:

updateSnitch in interface StorageServiceMBean

Parameters:

epSnitchClassName - the canonical path name for a class implementing IEndpointSnitch

dynamic - boolean that decides whether dynamicsnitch is used or not - only valid, if epSnitchClassName is specified

dynamicUpdateInterval - integer, in ms (defaults to the value configured in cassandra.yaml, which defaults to 100)

dynamicResetInterval - integer, in ms (defaults to the value configured in cassandra.yaml, which defaults to 600,000)

dynamicBadnessThreshold - double, (defaults to the value configured in cassandra.yaml, which defaults to 0.0)

Throws:

ClassNotFoundException

getBatchlogEndpointStrategy

public String getBatchlogEndpointStrategy()

Specified by:

getBatchlogEndpointStrategy in interface StorageServiceMBean

setBatchlogEndpointStrategy

public void setBatchlogEndpointStrategy(String batchlogEndpointStrategy)

Description copied from interface: StorageServiceMBean

See Config.BatchlogEndpointStrategy for valid values.

Specified by:

setBatchlogEndpointStrategy in interface StorageServiceMBean

bulkLoad

public void bulkLoad(String directory)

Description copied from interface: StorageServiceMBean

Starts a bulk load and blocks until it completes.

Specified by:

bulkLoad in interface StorageServiceMBean

bulkLoadAsync

public String bulkLoadAsync(String directory)

Description copied from interface: StorageServiceMBean

Starts a bulk load asynchronously and returns the String representation of the planID for the new streaming session.

Specified by:

bulkLoadAsync in interface StorageServiceMBean

rescheduleFailedDeletions

public void rescheduleFailedDeletions()

Specified by:

rescheduleFailedDeletions in interface StorageServiceMBean

loadNewSSTables

@Deprecated(since="4.0")
public void loadNewSSTables(String ksName,
 String cfName)

Deprecated.

See CASSANDRA-14417

Description copied from interface: StorageServiceMBean

Load new SSTables to the given keyspace/table

Specified by:

loadNewSSTables in interface StorageServiceMBean

Parameters:

ksName - The parent keyspace name

cfName - The ColumnFamily name where SSTables belong

See Also:

• ColumnFamilyStoreMBean.loadNewSSTables()

sampleKeyRange

public List<String> sampleKeyRange()

#Return a List of Tokens representing a sample of keys across all ColumnFamilyStores. Note: this should be left as an operation, not an attribute (methods starting with "get") to avoid sending potentially multiple MB of data when accessing this mbean by default. See CASSANDRA-4452.

Specified by:

sampleKeyRange in interface StorageServiceMBean

Returns:

set of Tokens as Strings

samplePartitions

public Map<String,List<CompositeData>> samplePartitions(int duration,
 int capacity,
 int count,
 List<String> samplers)
                                                 throws OpenDataException

Specified by:

samplePartitions in interface StorageServiceMBean

Throws:

OpenDataException

samplePartitions

public Map<String,List<CompositeData>> samplePartitions(String keyspace,
 int durationMillis,
 int capacity,
 int count,
 List<String> samplers)
                                                 throws OpenDataException

Specified by:

samplePartitions in interface StorageServiceMBean

Throws:

OpenDataException

startSamplingPartitions

public boolean startSamplingPartitions(String ks,
 String table,
 int duration,
 int interval,
 int capacity,
 int count,
 List<String> samplers)

Description copied from interface: StorageServiceMBean

Start a scheduled sampling

Specified by:

startSamplingPartitions in interface StorageServiceMBean

Parameters:

ks - Keyspace. Nullable. If null, the scheduled sampling is on all keyspaces and tables

table - Nullable. If null, the scheduled sampling is on all tables of the specified keyspace

duration - Duration of each scheduled sampling job in milliseconds

interval - Interval of each scheduled sampling job in milliseconds

capacity - Capacity of the sampler, higher for more accuracy

count - Number of the top samples to list

samplers - a list of samplers to enable

Returns:

true if the scheduled sampling is started successfully. Otherwise return false

stopSamplingPartitions

public boolean stopSamplingPartitions(String ks,
 String table)

Description copied from interface: StorageServiceMBean

Stop a scheduled sampling

Specified by:

stopSamplingPartitions in interface StorageServiceMBean

Parameters:

ks - Keyspace. Nullable. If null, the scheduled sampling is on all keysapces and tables

table - Nullable. If null, the scheduled sampling is on all tables of the specified keyspace

Returns:

true if the scheduled sampling is stopped. False is returned if the sampling task is not found

getSampleTasks

public List<String> getSampleTasks()

Specified by:

getSampleTasks in interface StorageServiceMBean

Returns:

a list of qualified table names that have active scheduled sampling tasks. The format of the name is `KEYSPACE.TABLE` The wild card symbol (*) indicates all keyspace/table. For example, "*.*" indicates all tables in all keyspaces. "foo.*" indicates all tables under keyspace 'foo'. "foo.bar" indicates the scheduled sampling is enabled for the table 'bar'

rebuildSecondaryIndex

public void rebuildSecondaryIndex(String ksName,
 String cfName,
 String... idxNames)

Description copied from interface: StorageServiceMBean

rebuild the specified indexes

Specified by:

rebuildSecondaryIndex in interface StorageServiceMBean

resetLocalSchema

public void resetLocalSchema()
                      throws IOException

Specified by:

resetLocalSchema in interface StorageServiceMBean

Throws:

IOException

reloadLocalSchema

public void reloadLocalSchema()

Specified by:

reloadLocalSchema in interface StorageServiceMBean

setTraceProbability

public void setTraceProbability(double probability)

Description copied from interface: StorageServiceMBean

Enables/Disables tracing for the whole system.

Specified by:

setTraceProbability in interface StorageServiceMBean

Parameters:

probability - ]0,1[ will enable tracing on a partial number of requests with the provided probability. 0 will disable tracing and 1 will enable tracing for all requests (which mich severely cripple the system)

getTraceProbability

public double getTraceProbability()

Description copied from interface: StorageServiceMBean

Returns the configured tracing probability.

Specified by:

getTraceProbability in interface StorageServiceMBean

shouldTraceProbablistically

public boolean shouldTraceProbablistically()

disableAutoCompaction

public void disableAutoCompaction(String ks,
 String... tables)
                           throws IOException

Specified by:

disableAutoCompaction in interface StorageServiceMBean

Throws:

IOException

enableAutoCompaction

public void enableAutoCompaction(String ks,
 String... tables)
                          throws IOException

Specified by:

enableAutoCompaction in interface StorageServiceMBean

Throws:

IOException

getAutoCompactionStatus

public Map<String,Boolean> getAutoCompactionStatus(String ks,
 String... tables)
                                            throws IOException

Specified by:

getAutoCompactionStatus in interface StorageServiceMBean

Throws:

IOException

getClusterName

public String getClusterName()

Returns the name of the cluster

Specified by:

getClusterName in interface StorageServiceMBean

getPartitionerName

public String getPartitionerName()

Returns the cluster partitioner

Specified by:

getPartitionerName in interface StorageServiceMBean

setSSTablePreemptiveOpenIntervalInMB

public void setSSTablePreemptiveOpenIntervalInMB(int intervalInMB)

Negative number for disabled

Specified by:

setSSTablePreemptiveOpenIntervalInMB in interface StorageServiceMBean

getSSTablePreemptiveOpenIntervalInMB

public int getSSTablePreemptiveOpenIntervalInMB()

This method can return negative number for disabled

Specified by:

getSSTablePreemptiveOpenIntervalInMB in interface StorageServiceMBean

getMigrateKeycacheOnCompaction

public boolean getMigrateKeycacheOnCompaction()

Specified by:

getMigrateKeycacheOnCompaction in interface StorageServiceMBean

setMigrateKeycacheOnCompaction

public void setMigrateKeycacheOnCompaction(boolean invalidateKeyCacheOnCompaction)

Specified by:

setMigrateKeycacheOnCompaction in interface StorageServiceMBean

getInvalidateKeycacheOnSSTableDeletion

public boolean getInvalidateKeycacheOnSSTableDeletion()

Specified by:

getInvalidateKeycacheOnSSTableDeletion in interface StorageServiceMBean

setInvalidateKeycacheOnSSTableDeletion

public void setInvalidateKeycacheOnSSTableDeletion(boolean invalidate)

Specified by:

setInvalidateKeycacheOnSSTableDeletion in interface StorageServiceMBean

getTombstoneWarnThreshold

public int getTombstoneWarnThreshold()

Description copied from interface: StorageServiceMBean

Returns the threshold for warning of queries with many tombstones

Specified by:

getTombstoneWarnThreshold in interface StorageServiceMBean

setTombstoneWarnThreshold

public void setTombstoneWarnThreshold(int threshold)

Description copied from interface: StorageServiceMBean

Sets the threshold for warning queries with many tombstones

Specified by:

setTombstoneWarnThreshold in interface StorageServiceMBean

getTombstoneFailureThreshold

public int getTombstoneFailureThreshold()

Description copied from interface: StorageServiceMBean

Returns the threshold for abandoning queries with many tombstones

Specified by:

getTombstoneFailureThreshold in interface StorageServiceMBean

setTombstoneFailureThreshold

public void setTombstoneFailureThreshold(int threshold)

Description copied from interface: StorageServiceMBean

Sets the threshold for abandoning queries with many tombstones

Specified by:

setTombstoneFailureThreshold in interface StorageServiceMBean

getCachedReplicaRowsWarnThreshold

public int getCachedReplicaRowsWarnThreshold()

Description copied from interface: StorageServiceMBean

Returns the number of rows cached at the coordinator before filtering/index queries log a warning.

Specified by:

getCachedReplicaRowsWarnThreshold in interface StorageServiceMBean

setCachedReplicaRowsWarnThreshold

public void setCachedReplicaRowsWarnThreshold(int threshold)

Description copied from interface: StorageServiceMBean

Sets the number of rows cached at the coordinator before filtering/index queries log a warning.

Specified by:

setCachedReplicaRowsWarnThreshold in interface StorageServiceMBean

getCachedReplicaRowsFailThreshold

public int getCachedReplicaRowsFailThreshold()

Description copied from interface: StorageServiceMBean

Returns the number of rows cached at the coordinator before filtering/index queries fail outright.

Specified by:

getCachedReplicaRowsFailThreshold in interface StorageServiceMBean

setCachedReplicaRowsFailThreshold

public void setCachedReplicaRowsFailThreshold(int threshold)

Description copied from interface: StorageServiceMBean

Sets the number of rows cached at the coordinator before filtering/index queries fail outright.

Specified by:

setCachedReplicaRowsFailThreshold in interface StorageServiceMBean

getColumnIndexSizeInKiB

public int getColumnIndexSizeInKiB()

Description copied from interface: StorageServiceMBean

Returns the granularity of the collation index of rows within a partition. -1 stands for the SSTable format's default.

Specified by:

getColumnIndexSizeInKiB in interface StorageServiceMBean

setColumnIndexSizeInKiB

public void setColumnIndexSizeInKiB(int columnIndexSizeInKiB)

Description copied from interface: StorageServiceMBean

Sets the granularity of the collation index of rows within a partition. Use -1 to select the SSTable format's default.

Specified by:

setColumnIndexSizeInKiB in interface StorageServiceMBean

setColumnIndexSize

@Deprecated(since="5.0")
public void setColumnIndexSize(int columnIndexSizeInKB)

Deprecated.

See CASSANDRA-17668

Description copied from interface: StorageServiceMBean

Sets the granularity of the collation index of rows within a partition

Specified by:

setColumnIndexSize in interface StorageServiceMBean

getColumnIndexCacheSize

@Deprecated(since="5.0")
public int getColumnIndexCacheSize()

Deprecated.

See CASSANDRA-17668

Description copied from interface: StorageServiceMBean

Returns the threshold for skipping the column index when caching partition info

Specified by:

getColumnIndexCacheSize in interface StorageServiceMBean

setColumnIndexCacheSize

@Deprecated(since="5.0")
public void setColumnIndexCacheSize(int cacheSizeInKB)

Deprecated.

See CASSANDRA-17668

Description copied from interface: StorageServiceMBean

Sets the threshold for skipping the column index when caching partition info

Specified by:

setColumnIndexCacheSize in interface StorageServiceMBean

getColumnIndexCacheSizeInKiB

public int getColumnIndexCacheSizeInKiB()

Description copied from interface: StorageServiceMBean

Returns the threshold for skipping the column index when caching partition info

Specified by:

getColumnIndexCacheSizeInKiB in interface StorageServiceMBean

setColumnIndexCacheSizeInKiB

public void setColumnIndexCacheSizeInKiB(int cacheSizeInKiB)

Description copied from interface: StorageServiceMBean

Sets the threshold for skipping the column index when caching partition info

Specified by:

setColumnIndexCacheSizeInKiB in interface StorageServiceMBean

getBatchSizeFailureThreshold

public int getBatchSizeFailureThreshold()

Description copied from interface: StorageServiceMBean

Returns the threshold for rejecting queries due to a large batch size

Specified by:

getBatchSizeFailureThreshold in interface StorageServiceMBean

setBatchSizeFailureThreshold

public void setBatchSizeFailureThreshold(int threshold)

Description copied from interface: StorageServiceMBean

Sets the threshold for rejecting queries due to a large batch size

Specified by:

setBatchSizeFailureThreshold in interface StorageServiceMBean

getBatchSizeWarnThreshold

@Deprecated(since="5.0")
public int getBatchSizeWarnThreshold()

Deprecated.

See CASSANDRA-17668

Description copied from interface: StorageServiceMBean

Returns the threshold for warning queries due to a large batch size

Specified by:

getBatchSizeWarnThreshold in interface StorageServiceMBean

setBatchSizeWarnThreshold

@Deprecated(since="5.0")
public void setBatchSizeWarnThreshold(int threshold)

Deprecated.

See CASSANDRA-17668

Description copied from interface: StorageServiceMBean

Sets the threshold for warning queries due to a large batch size

Specified by:

setBatchSizeWarnThreshold in interface StorageServiceMBean

getBatchSizeWarnThresholdInKiB

public int getBatchSizeWarnThresholdInKiB()

Description copied from interface: StorageServiceMBean

Returns the threshold for warning queries due to a large batch size

Specified by:

getBatchSizeWarnThresholdInKiB in interface StorageServiceMBean

setBatchSizeWarnThresholdInKiB

public void setBatchSizeWarnThresholdInKiB(int thresholdInKiB)

Description copied from interface: StorageServiceMBean

Sets the threshold for warning queries due to a large batch size

Specified by:

setBatchSizeWarnThresholdInKiB in interface StorageServiceMBean

getInitialRangeTombstoneListAllocationSize

public int getInitialRangeTombstoneListAllocationSize()

Description copied from interface: StorageServiceMBean

Returns the initial allocation size of backing arrays for new RangeTombstoneList objects

Specified by:

getInitialRangeTombstoneListAllocationSize in interface StorageServiceMBean

setInitialRangeTombstoneListAllocationSize

public void setInitialRangeTombstoneListAllocationSize(int size)

Description copied from interface: StorageServiceMBean

Sets the initial allocation size of backing arrays for new RangeTombstoneList objects

Specified by:

setInitialRangeTombstoneListAllocationSize in interface StorageServiceMBean

getRangeTombstoneResizeListGrowthFactor

public double getRangeTombstoneResizeListGrowthFactor()

Description copied from interface: StorageServiceMBean

Returns the resize factor to use when growing/resizing a RangeTombstoneList

Specified by:

getRangeTombstoneResizeListGrowthFactor in interface StorageServiceMBean

setRangeTombstoneListResizeGrowthFactor

public void setRangeTombstoneListResizeGrowthFactor(double growthFactor)
                                             throws IllegalStateException

Description copied from interface: StorageServiceMBean

Sets the resize factor to use when growing/resizing a RangeTombstoneList

Specified by:

setRangeTombstoneListResizeGrowthFactor in interface StorageServiceMBean

Throws:

IllegalStateException

setHintedHandoffThrottleInKB

public void setHintedHandoffThrottleInKB(int throttleInKB)

Description copied from interface: StorageServiceMBean

Sets the hinted handoff throttle in KiB per second, per delivery thread.

Specified by:

setHintedHandoffThrottleInKB in interface StorageServiceMBean

getTransferHintsOnDecommission

public boolean getTransferHintsOnDecommission()

Specified by:

getTransferHintsOnDecommission in interface StorageServiceMBean

setTransferHintsOnDecommission

public void setTransferHintsOnDecommission(boolean enabled)

Specified by:

setTransferHintsOnDecommission in interface StorageServiceMBean

isHintTtlUseMutationCreationTime

public boolean isHintTtlUseMutationCreationTime()

Description copied from interface: StorageServiceMBean

Returns whether we are using the creation time of the mutation for determining hint ttl

Specified by:

isHintTtlUseMutationCreationTime in interface StorageServiceMBean

setUseCreationTimeForHintTtl

public void setUseCreationTimeForHintTtl(boolean enabled)

Description copied from interface: StorageServiceMBean

Sets whether we are using the creation time of the mutation for determining hint ttl

Specified by:

setUseCreationTimeForHintTtl in interface StorageServiceMBean

getMaxHintTTL

public int getMaxHintTTL()

Description copied from interface: StorageServiceMBean

Returns upper bound on the hint ttl

Specified by:

getMaxHintTTL in interface StorageServiceMBean

setMaxHintTTL

public void setMaxHintTTL(int maxHintTTL)

Description copied from interface: StorageServiceMBean

Sets the upper bound on the hint ttl

Specified by:

setMaxHintTTL in interface StorageServiceMBean

clearConnectionHistory

public void clearConnectionHistory()

Description copied from interface: StorageServiceMBean

Clears the history of clients that have connected in the past

Specified by:

clearConnectionHistory in interface StorageServiceMBean

disableAuditLog

public void disableAuditLog()

Specified by:

disableAuditLog in interface StorageServiceMBean

enableAuditLog

@Deprecated(since="4.1")
public void enableAuditLog(String loggerName,
 String includedKeyspaces,
 String excludedKeyspaces,
 String includedCategories,
 String excludedCategories,
 String includedUsers,
 String excludedUsers)
                    throws ConfigurationException,
IllegalStateException

Deprecated.

See CASSANDRA-16725

Specified by:

enableAuditLog in interface StorageServiceMBean

Throws:

ConfigurationException

IllegalStateException

enableAuditLog

public void enableAuditLog(String loggerName,
 String includedKeyspaces,
 String excludedKeyspaces,
 String includedCategories,
 String excludedCategories,
 String includedUsers,
 String excludedUsers,
 Integer maxArchiveRetries,
 Boolean block,
 String rollCycle,
 Long maxLogSize,
 Integer maxQueueWeight,
 String archiveCommand)
                    throws IllegalStateException

Specified by:

enableAuditLog in interface StorageServiceMBean

Throws:

IllegalStateException

enableAuditLog

@Deprecated(since="4.1")
public void enableAuditLog(String loggerName,
 Map<String,String> parameters,
 String includedKeyspaces,
 String excludedKeyspaces,
 String includedCategories,
 String excludedCategories,
 String includedUsers,
 String excludedUsers)
                    throws ConfigurationException,
IllegalStateException

Deprecated.

See CASSANDRA-16725

Specified by:

enableAuditLog in interface StorageServiceMBean

Throws:

ConfigurationException

IllegalStateException

enableAuditLog

public void enableAuditLog(String loggerName,
 Map<String,String> parameters,
 String includedKeyspaces,
 String excludedKeyspaces,
 String includedCategories,
 String excludedCategories,
 String includedUsers,
 String excludedUsers,
 Integer maxArchiveRetries,
 Boolean block,
 String rollCycle,
 Long maxLogSize,
 Integer maxQueueWeight,
 String archiveCommand)
                    throws IllegalStateException

Specified by:

enableAuditLog in interface StorageServiceMBean

Throws:

IllegalStateException

isAuditLogEnabled

public boolean isAuditLogEnabled()

Specified by:

isAuditLogEnabled in interface StorageServiceMBean

getCorruptedTombstoneStrategy

public String getCorruptedTombstoneStrategy()

Specified by:

getCorruptedTombstoneStrategy in interface StorageServiceMBean

setCorruptedTombstoneStrategy

public void setCorruptedTombstoneStrategy(String strategy)

Specified by:

setCorruptedTombstoneStrategy in interface StorageServiceMBean

getNativeTransportMaxConcurrentRequestsInBytes

public long getNativeTransportMaxConcurrentRequestsInBytes()

Specified by:

getNativeTransportMaxConcurrentRequestsInBytes in interface StorageServiceMBean

setNativeTransportMaxConcurrentRequestsInBytes

public void setNativeTransportMaxConcurrentRequestsInBytes(long newLimit)

Specified by:

setNativeTransportMaxConcurrentRequestsInBytes in interface StorageServiceMBean

getNativeTransportMaxConcurrentRequestsInBytesPerIp

public long getNativeTransportMaxConcurrentRequestsInBytesPerIp()

Specified by:

getNativeTransportMaxConcurrentRequestsInBytesPerIp in interface StorageServiceMBean

setNativeTransportMaxConcurrentRequestsInBytesPerIp

public void setNativeTransportMaxConcurrentRequestsInBytesPerIp(long newLimit)

Specified by:

setNativeTransportMaxConcurrentRequestsInBytesPerIp in interface StorageServiceMBean

getNativeTransportMaxRequestsPerSecond

public int getNativeTransportMaxRequestsPerSecond()

Specified by:

getNativeTransportMaxRequestsPerSecond in interface StorageServiceMBean

setNativeTransportMaxRequestsPerSecond

public void setNativeTransportMaxRequestsPerSecond(int newPerSecond)

Specified by:

setNativeTransportMaxRequestsPerSecond in interface StorageServiceMBean

setNativeTransportRateLimitingEnabled

public void setNativeTransportRateLimitingEnabled(boolean enabled)

Specified by:

setNativeTransportRateLimitingEnabled in interface StorageServiceMBean

getNativeTransportRateLimitingEnabled

public boolean getNativeTransportRateLimitingEnabled()

Specified by:

getNativeTransportRateLimitingEnabled in interface StorageServiceMBean

isOutOfTokenRangeRequestLoggingEnabled

public boolean isOutOfTokenRangeRequestLoggingEnabled()

Description copied from interface: StorageServiceMBean

Toggles to turn on the logging or rejection of operations for token ranges that the node does not own, or is not about to acquire.

Specified by:

isOutOfTokenRangeRequestLoggingEnabled in interface StorageServiceMBean

setOutOfTokenRangeRequestLoggingEnabled

public void setOutOfTokenRangeRequestLoggingEnabled(boolean enabled)

Specified by:

setOutOfTokenRangeRequestLoggingEnabled in interface StorageServiceMBean

isOutOfTokenRangeRequestRejectionEnabled

public boolean isOutOfTokenRangeRequestRejectionEnabled()

Specified by:

isOutOfTokenRangeRequestRejectionEnabled in interface StorageServiceMBean

setOutOfTokenRangeRequestRejectionEnabled

public void setOutOfTokenRangeRequestRejectionEnabled(boolean enabled)

Specified by:

setOutOfTokenRangeRequestRejectionEnabled in interface StorageServiceMBean

shutdownServer

public void shutdownServer()

enableFullQueryLogger

public void enableFullQueryLogger(String path,
 String rollCycle,
 Boolean blocking,
 int maxQueueWeight,
 long maxLogSize,
 String archiveCommand,
 int maxArchiveRetries)

Description copied from interface: StorageServiceMBean

Start the fully query logger.

Specified by:

enableFullQueryLogger in interface StorageServiceMBean

Parameters:

path - Path where the full query log will be stored. If null cassandra.yaml value is used.

rollCycle - How often to create a new file for query data (MINUTELY, DAILY, HOURLY)

blocking - Whether threads submitting queries to the query log should block if they can't be drained to the filesystem or alternatively drops samples and log

maxQueueWeight - How many bytes of query data to queue before blocking or dropping samples

maxLogSize - How many bytes of log data to store before dropping segments. Might not be respected if a log file hasn't rolled so it can be deleted.

archiveCommand - executable archiving the rolled log files,

maxArchiveRetries - max number of times to retry a failing archive command

resetFullQueryLogger

public void resetFullQueryLogger()

Description copied from interface: StorageServiceMBean

Disable the full query logger if it is enabled. Also delete any generated files in the last used full query log path as well as the one configure in cassandra.yaml

Specified by:

resetFullQueryLogger in interface StorageServiceMBean

stopFullQueryLogger

public void stopFullQueryLogger()

Description copied from interface: StorageServiceMBean

Stop logging queries but leave any generated files on disk.

Specified by:

stopFullQueryLogger in interface StorageServiceMBean

isFullQueryLogEnabled

public boolean isFullQueryLogEnabled()

Specified by:

isFullQueryLogEnabled in interface StorageServiceMBean

getFullQueryLoggerOptions

public CompositeData getFullQueryLoggerOptions()

Description copied from interface: StorageServiceMBean

Returns the current state of FQL.

Specified by:

getFullQueryLoggerOptions in interface StorageServiceMBean

getOutstandingSchemaVersions

public Map<String,Set<InetAddress>> getOutstandingSchemaVersions()

Description copied from interface: StorageServiceMBean

Returns a map of schema version -> list of endpoints reporting that version that we need schema updates for

Specified by:

getOutstandingSchemaVersions in interface StorageServiceMBean

getOutstandingSchemaVersionsWithPort

public Map<String,Set<String>> getOutstandingSchemaVersionsWithPort()

Specified by:

getOutstandingSchemaVersionsWithPort in interface StorageServiceMBean

autoOptimiseIncRepairStreams

public boolean autoOptimiseIncRepairStreams()

Specified by:

autoOptimiseIncRepairStreams in interface StorageServiceMBean

setAutoOptimiseIncRepairStreams

public void setAutoOptimiseIncRepairStreams(boolean enabled)

Specified by:

setAutoOptimiseIncRepairStreams in interface StorageServiceMBean

autoOptimiseFullRepairStreams

public boolean autoOptimiseFullRepairStreams()

Specified by:

autoOptimiseFullRepairStreams in interface StorageServiceMBean

setAutoOptimiseFullRepairStreams

public void setAutoOptimiseFullRepairStreams(boolean enabled)

Specified by:

setAutoOptimiseFullRepairStreams in interface StorageServiceMBean

autoOptimisePreviewRepairStreams

public boolean autoOptimisePreviewRepairStreams()

Specified by:

autoOptimisePreviewRepairStreams in interface StorageServiceMBean

setAutoOptimisePreviewRepairStreams

public void setAutoOptimisePreviewRepairStreams(boolean enabled)

Specified by:

setAutoOptimisePreviewRepairStreams in interface StorageServiceMBean

getTableCountWarnThreshold

@Deprecated(since="4.1")
public int getTableCountWarnThreshold()

Deprecated.

See CASSANDRA-17195

Specified by:

getTableCountWarnThreshold in interface StorageServiceMBean

setTableCountWarnThreshold

@Deprecated(since="4.1")
public void setTableCountWarnThreshold(int value)

Deprecated.

See CASSANDRA-17195

Specified by:

setTableCountWarnThreshold in interface StorageServiceMBean

getKeyspaceCountWarnThreshold

@Deprecated(since="4.1")
public int getKeyspaceCountWarnThreshold()

Deprecated.

See CASSANDRA-17195

Specified by:

getKeyspaceCountWarnThreshold in interface StorageServiceMBean

setKeyspaceCountWarnThreshold

@Deprecated(since="4.1")
public void setKeyspaceCountWarnThreshold(int value)

Deprecated.

See CASSANDRA-17195

Specified by:

setKeyspaceCountWarnThreshold in interface StorageServiceMBean

setCompactionTombstoneWarningThreshold

public void setCompactionTombstoneWarningThreshold(int count)

Specified by:

setCompactionTombstoneWarningThreshold in interface StorageServiceMBean

getCompactionTombstoneWarningThreshold

public int getCompactionTombstoneWarningThreshold()

Specified by:

getCompactionTombstoneWarningThreshold in interface StorageServiceMBean

addSnapshot

public void addSnapshot(TableSnapshot snapshot)

getReadThresholdsEnabled

public boolean getReadThresholdsEnabled()

Specified by:

getReadThresholdsEnabled in interface StorageServiceMBean

setReadThresholdsEnabled

public void setReadThresholdsEnabled(boolean value)

Specified by:

setReadThresholdsEnabled in interface StorageServiceMBean

getCoordinatorLargeReadWarnThreshold

public String getCoordinatorLargeReadWarnThreshold()

Specified by:

getCoordinatorLargeReadWarnThreshold in interface StorageServiceMBean

setCoordinatorLargeReadWarnThreshold

public void setCoordinatorLargeReadWarnThreshold(String threshold)

Specified by:

setCoordinatorLargeReadWarnThreshold in interface StorageServiceMBean

getCoordinatorLargeReadAbortThreshold

public String getCoordinatorLargeReadAbortThreshold()

Specified by:

getCoordinatorLargeReadAbortThreshold in interface StorageServiceMBean

setCoordinatorLargeReadAbortThreshold

public void setCoordinatorLargeReadAbortThreshold(String threshold)

Specified by:

setCoordinatorLargeReadAbortThreshold in interface StorageServiceMBean

getLocalReadTooLargeWarnThreshold

public String getLocalReadTooLargeWarnThreshold()

Specified by:

getLocalReadTooLargeWarnThreshold in interface StorageServiceMBean

setLocalReadTooLargeWarnThreshold

public void setLocalReadTooLargeWarnThreshold(String threshold)

Specified by:

setLocalReadTooLargeWarnThreshold in interface StorageServiceMBean

getLocalReadTooLargeAbortThreshold

public String getLocalReadTooLargeAbortThreshold()

Specified by:

getLocalReadTooLargeAbortThreshold in interface StorageServiceMBean

setLocalReadTooLargeAbortThreshold

public void setLocalReadTooLargeAbortThreshold(String threshold)

Specified by:

setLocalReadTooLargeAbortThreshold in interface StorageServiceMBean

getRowIndexReadSizeWarnThreshold

public String getRowIndexReadSizeWarnThreshold()

Specified by:

getRowIndexReadSizeWarnThreshold in interface StorageServiceMBean

setRowIndexReadSizeWarnThreshold

public void setRowIndexReadSizeWarnThreshold(String threshold)

Specified by:

setRowIndexReadSizeWarnThreshold in interface StorageServiceMBean

getRowIndexReadSizeAbortThreshold

public String getRowIndexReadSizeAbortThreshold()

Specified by:

getRowIndexReadSizeAbortThreshold in interface StorageServiceMBean

setRowIndexReadSizeAbortThreshold

public void setRowIndexReadSizeAbortThreshold(String threshold)

Specified by:

setRowIndexReadSizeAbortThreshold in interface StorageServiceMBean

setDefaultKeyspaceReplicationFactor

public void setDefaultKeyspaceReplicationFactor(int value)

Specified by:

setDefaultKeyspaceReplicationFactor in interface StorageServiceMBean

getDefaultKeyspaceReplicationFactor

public int getDefaultKeyspaceReplicationFactor()

Specified by:

getDefaultKeyspaceReplicationFactor in interface StorageServiceMBean

getSkipPaxosRepairOnTopologyChange

public boolean getSkipPaxosRepairOnTopologyChange()

Specified by:

getSkipPaxosRepairOnTopologyChange in interface StorageServiceMBean

setSkipPaxosRepairOnTopologyChange

public void setSkipPaxosRepairOnTopologyChange(boolean v)

Specified by:

setSkipPaxosRepairOnTopologyChange in interface StorageServiceMBean

getSkipPaxosRepairOnTopologyChangeKeyspaces

public String getSkipPaxosRepairOnTopologyChangeKeyspaces()

Specified by:

getSkipPaxosRepairOnTopologyChangeKeyspaces in interface StorageServiceMBean

setSkipPaxosRepairOnTopologyChangeKeyspaces

public void setSkipPaxosRepairOnTopologyChangeKeyspaces(String v)

Specified by:

setSkipPaxosRepairOnTopologyChangeKeyspaces in interface StorageServiceMBean

getPaxosAutoRepairsEnabled

public boolean getPaxosAutoRepairsEnabled()

Specified by:

getPaxosAutoRepairsEnabled in interface StorageServiceMBean

setPaxosAutoRepairsEnabled

public void setPaxosAutoRepairsEnabled(boolean enabled)

Specified by:

setPaxosAutoRepairsEnabled in interface StorageServiceMBean

getPaxosStateFlushEnabled

public boolean getPaxosStateFlushEnabled()

Specified by:

getPaxosStateFlushEnabled in interface StorageServiceMBean

setPaxosStateFlushEnabled

public void setPaxosStateFlushEnabled(boolean enabled)

Specified by:

setPaxosStateFlushEnabled in interface StorageServiceMBean

getPaxosAutoRepairTables

public List<String> getPaxosAutoRepairTables()

Specified by:

getPaxosAutoRepairTables in interface StorageServiceMBean

getPaxosPurgeGraceSeconds

public long getPaxosPurgeGraceSeconds()

Specified by:

getPaxosPurgeGraceSeconds in interface StorageServiceMBean

setPaxosPurgeGraceSeconds

public void setPaxosPurgeGraceSeconds(long v)

Specified by:

setPaxosPurgeGraceSeconds in interface StorageServiceMBean

getPaxosOnLinearizabilityViolations

public String getPaxosOnLinearizabilityViolations()

Specified by:

getPaxosOnLinearizabilityViolations in interface StorageServiceMBean

setPaxosOnLinearizabilityViolations

public void setPaxosOnLinearizabilityViolations(String v)

Specified by:

setPaxosOnLinearizabilityViolations in interface StorageServiceMBean

getPaxosStatePurging

public String getPaxosStatePurging()

Specified by:

getPaxosStatePurging in interface StorageServiceMBean

setPaxosStatePurging

public void setPaxosStatePurging(String v)

Specified by:

setPaxosStatePurging in interface StorageServiceMBean

getPaxosRepairEnabled

public boolean getPaxosRepairEnabled()

Specified by:

getPaxosRepairEnabled in interface StorageServiceMBean

setPaxosRepairEnabled

public void setPaxosRepairEnabled(boolean enabled)

Specified by:

setPaxosRepairEnabled in interface StorageServiceMBean

getPaxosDcLocalCommitEnabled

public boolean getPaxosDcLocalCommitEnabled()

Specified by:

getPaxosDcLocalCommitEnabled in interface StorageServiceMBean

setPaxosDcLocalCommitEnabled

public void setPaxosDcLocalCommitEnabled(boolean enabled)

Specified by:

setPaxosDcLocalCommitEnabled in interface StorageServiceMBean

getPaxosBallotLowBound

public String getPaxosBallotLowBound(String ksName,
 String tblName,
 String key)

Specified by:

getPaxosBallotLowBound in interface StorageServiceMBean

getRepairRpcTimeout

public Long getRepairRpcTimeout()

Specified by:

getRepairRpcTimeout in interface StorageServiceMBean

setRepairRpcTimeout

public void setRepairRpcTimeout(Long timeoutInMillis)

Specified by:

setRepairRpcTimeout in interface StorageServiceMBean

evictHungRepairs

public void evictHungRepairs()

Specified by:

evictHungRepairs in interface StorageServiceMBean

clearPaxosRepairs

public void clearPaxosRepairs()

Specified by:

clearPaxosRepairs in interface StorageServiceMBean

setSkipPaxosRepairCompatibilityCheck

public void setSkipPaxosRepairCompatibilityCheck(boolean v)

Specified by:

setSkipPaxosRepairCompatibilityCheck in interface StorageServiceMBean

getSkipPaxosRepairCompatibilityCheck

public boolean getSkipPaxosRepairCompatibilityCheck()

Specified by:

getSkipPaxosRepairCompatibilityCheck in interface StorageServiceMBean

topPartitionsEnabled

public boolean topPartitionsEnabled()

Specified by:

topPartitionsEnabled in interface StorageServiceMBean

getMaxTopSizePartitionCount

public int getMaxTopSizePartitionCount()

Specified by:

getMaxTopSizePartitionCount in interface StorageServiceMBean

setMaxTopSizePartitionCount

public void setMaxTopSizePartitionCount(int value)

Specified by:

setMaxTopSizePartitionCount in interface StorageServiceMBean

getMaxTopTombstonePartitionCount

public int getMaxTopTombstonePartitionCount()

Specified by:

getMaxTopTombstonePartitionCount in interface StorageServiceMBean

setMaxTopTombstonePartitionCount

public void setMaxTopTombstonePartitionCount(int value)

Specified by:

setMaxTopTombstonePartitionCount in interface StorageServiceMBean

getMinTrackedPartitionSize

public String getMinTrackedPartitionSize()

Specified by:

getMinTrackedPartitionSize in interface StorageServiceMBean

setMinTrackedPartitionSize

public void setMinTrackedPartitionSize(String value)

Specified by:

setMinTrackedPartitionSize in interface StorageServiceMBean

getMinTrackedPartitionTombstoneCount

public long getMinTrackedPartitionTombstoneCount()

Specified by:

getMinTrackedPartitionTombstoneCount in interface StorageServiceMBean

setMinTrackedPartitionTombstoneCount

public void setMinTrackedPartitionTombstoneCount(long value)

Specified by:

setMinTrackedPartitionTombstoneCount in interface StorageServiceMBean

setSkipStreamDiskSpaceCheck

public void setSkipStreamDiskSpaceCheck(boolean value)

Specified by:

setSkipStreamDiskSpaceCheck in interface StorageServiceMBean

getSkipStreamDiskSpaceCheck

public boolean getSkipStreamDiskSpaceCheck()

Specified by:

getSkipStreamDiskSpaceCheck in interface StorageServiceMBean

removeNotificationListener

public void removeNotificationListener(NotificationListener listener)
                                throws ListenerNotFoundException

Specified by:

removeNotificationListener in interface NotificationBroadcaster

Overrides:

removeNotificationListener in class NotificationBroadcasterSupport

Throws:

ListenerNotFoundException

removeNotificationListener

public void removeNotificationListener(NotificationListener listener,
 NotificationFilter filter,
 Object handback)
                                throws ListenerNotFoundException

Specified by:

removeNotificationListener in interface NotificationEmitter

Overrides:

removeNotificationListener in class NotificationBroadcasterSupport

Throws:

ListenerNotFoundException

addNotificationListener

public void addNotificationListener(NotificationListener listener,
 NotificationFilter filter,
 Object handback)
                             throws IllegalArgumentException

Specified by:

addNotificationListener in interface NotificationBroadcaster

Overrides:

addNotificationListener in class NotificationBroadcasterSupport

Throws:

IllegalArgumentException

getNativeTransportQueueMaxItemAgeThreshold

public double getNativeTransportQueueMaxItemAgeThreshold()

Specified by:

getNativeTransportQueueMaxItemAgeThreshold in interface StorageServiceMBean

setNativeTransportQueueMaxItemAgeThreshold

public void setNativeTransportQueueMaxItemAgeThreshold(double threshold)

Specified by:

setNativeTransportQueueMaxItemAgeThreshold in interface StorageServiceMBean

getNativeTransportMinBackoffOnQueueOverloadInMillis

public long getNativeTransportMinBackoffOnQueueOverloadInMillis()

Specified by:

getNativeTransportMinBackoffOnQueueOverloadInMillis in interface StorageServiceMBean

getNativeTransportMaxBackoffOnQueueOverloadInMillis

public long getNativeTransportMaxBackoffOnQueueOverloadInMillis()

Specified by:

getNativeTransportMaxBackoffOnQueueOverloadInMillis in interface StorageServiceMBean

setNativeTransportBackoffOnQueueOverloadInMillis

public void setNativeTransportBackoffOnQueueOverloadInMillis(long min,
 long max)

Specified by:

setNativeTransportBackoffOnQueueOverloadInMillis in interface StorageServiceMBean

getNativeTransportThrowOnOverload

public boolean getNativeTransportThrowOnOverload()

Specified by:

getNativeTransportThrowOnOverload in interface StorageServiceMBean

setNativeTransportThrowOnOverload

public void setNativeTransportThrowOnOverload(boolean throwOnOverload)

Specified by:

setNativeTransportThrowOnOverload in interface StorageServiceMBean

getNativeTransportTimeoutMillis

public long getNativeTransportTimeoutMillis()

Specified by:

getNativeTransportTimeoutMillis in interface StorageServiceMBean

setNativeTransportTimeoutMillis

public void setNativeTransportTimeoutMillis(long deadlineMillis)

Specified by:

setNativeTransportTimeoutMillis in interface StorageServiceMBean

getEnforceNativeDeadlineForHints

public boolean getEnforceNativeDeadlineForHints()

Specified by:

getEnforceNativeDeadlineForHints in interface StorageServiceMBean

setEnforceNativeDeadlineForHints

public void setEnforceNativeDeadlineForHints(boolean value)

Specified by:

setEnforceNativeDeadlineForHints in interface StorageServiceMBean

getPrioritizeSAIOverLegacyIndex

public boolean getPrioritizeSAIOverLegacyIndex()

Specified by:

getPrioritizeSAIOverLegacyIndex in interface StorageServiceMBean

setPrioritizeSAIOverLegacyIndex

public void setPrioritizeSAIOverLegacyIndex(boolean value)

Specified by:

setPrioritizeSAIOverLegacyIndex in interface StorageServiceMBean

getForceOptimizedIndexStatusFormat

public boolean getForceOptimizedIndexStatusFormat()

Specified by:

getForceOptimizedIndexStatusFormat in interface StorageServiceMBean

setForceOptimizedIndexStatusFormat

public void setForceOptimizedIndexStatusFormat(boolean value)

Specified by:

setForceOptimizedIndexStatusFormat in interface StorageServiceMBean

setPaxosRepairRaceWait

public void setPaxosRepairRaceWait(boolean paxosRepairRaceWait)

Specified by:

setPaxosRepairRaceWait in interface StorageServiceMBean

getPaxosRepairRaceWait

public boolean getPaxosRepairRaceWait()

Specified by:

getPaxosRepairRaceWait in interface StorageServiceMBean

getTablesForKeyspace

public List<String> getTablesForKeyspace(String keyspace)

Description copied from interface: StorageServiceMBean

Gets the names of all tables for the given keyspace

Specified by:

getTablesForKeyspace in interface StorageServiceMBean

mutateSSTableRepairedState

public List<String> mutateSSTableRepairedState(boolean repaired,
 boolean preview,
 String keyspace,
 List<String> tableNames)

Description copied from interface: StorageServiceMBean

Mutates the repaired state of all SSTables for the given SSTables

Specified by:

mutateSSTableRepairedState in interface StorageServiceMBean