Class NodeProbe

  • All Implemented Interfaces:
    java.lang.AutoCloseable

    public class NodeProbe
    extends java.lang.Object
    implements java.lang.AutoCloseable
    JMX client operations for Cassandra.
    • Constructor Detail

      • NodeProbe

        public NodeProbe​(java.lang.String host,
                         int port,
                         java.lang.String username,
                         java.lang.String password)
                  throws java.io.IOException
        Creates a NodeProbe using the specified JMX host, port, username, and password.
        Parameters:
        host - hostname or IP address of the JMX agent
        port - TCP port of the remote JMX agent
        Throws:
        java.io.IOException - on connection failures
      • NodeProbe

        public NodeProbe​(java.lang.String host,
                         int port)
                  throws java.io.IOException
        Creates a NodeProbe using the specified JMX host and port.
        Parameters:
        host - hostname or IP address of the JMX agent
        port - TCP port of the remote JMX agent
        Throws:
        java.io.IOException - on connection failures
      • NodeProbe

        public NodeProbe​(java.lang.String host)
                  throws java.io.IOException
        Creates a NodeProbe using the specified JMX host and default port.
        Parameters:
        host - hostname or IP address of the JMX agent
        Throws:
        java.io.IOException - on connection failures
      • NodeProbe

        protected NodeProbe()
    • Method Detail

      • connect

        protected void connect()
                        throws java.io.IOException
        Create a connection to the JMX agent and setup the M[X]Bean proxies.
        Throws:
        java.io.IOException - on connection failures
      • close

        public void close()
                   throws java.io.IOException
        Specified by:
        close in interface java.lang.AutoCloseable
        Throws:
        java.io.IOException
      • setOutput

        public void setOutput​(Output output)
      • output

        public Output output()
      • forceKeyspaceCleanup

        public int forceKeyspaceCleanup​(int jobs,
                                        java.lang.String keyspaceName,
                                        java.lang.String... tables)
                                 throws java.io.IOException,
                                        java.util.concurrent.ExecutionException,
                                        java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • scrub

        public int scrub​(boolean disableSnapshot,
                         boolean skipCorrupted,
                         boolean checkData,
                         boolean reinsertOverflowedTTL,
                         int jobs,
                         java.lang.String keyspaceName,
                         java.lang.String... tables)
                  throws java.io.IOException,
                         java.util.concurrent.ExecutionException,
                         java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • verify

        public int verify​(boolean extendedVerify,
                          boolean checkVersion,
                          boolean diskFailurePolicy,
                          boolean mutateRepairStatus,
                          boolean checkOwnsTokens,
                          boolean quick,
                          java.lang.String keyspaceName,
                          java.lang.String... tableNames)
                   throws java.io.IOException,
                          java.util.concurrent.ExecutionException,
                          java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • upgradeSSTables

        public int upgradeSSTables​(java.lang.String keyspaceName,
                                   boolean excludeCurrentVersion,
                                   int jobs,
                                   java.lang.String... tableNames)
                            throws java.io.IOException,
                                   java.util.concurrent.ExecutionException,
                                   java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • garbageCollect

        public int garbageCollect​(java.lang.String tombstoneOption,
                                  int jobs,
                                  java.lang.String keyspaceName,
                                  java.lang.String... tableNames)
                           throws java.io.IOException,
                                  java.util.concurrent.ExecutionException,
                                  java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • forceKeyspaceCleanup

        public void forceKeyspaceCleanup​(java.io.PrintStream out,
                                         int jobs,
                                         java.lang.String keyspaceName,
                                         java.lang.String... tableNames)
                                  throws java.io.IOException,
                                         java.util.concurrent.ExecutionException,
                                         java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • scrub

        public void scrub​(java.io.PrintStream out,
                          boolean disableSnapshot,
                          boolean skipCorrupted,
                          boolean checkData,
                          boolean reinsertOverflowedTTL,
                          int jobs,
                          java.lang.String keyspaceName,
                          java.lang.String... tables)
                   throws java.io.IOException,
                          java.util.concurrent.ExecutionException,
                          java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • verify

        public void verify​(java.io.PrintStream out,
                           boolean extendedVerify,
                           boolean checkVersion,
                           boolean diskFailurePolicy,
                           boolean mutateRepairStatus,
                           boolean checkOwnsTokens,
                           boolean quick,
                           java.lang.String keyspaceName,
                           java.lang.String... tableNames)
                    throws java.io.IOException,
                           java.util.concurrent.ExecutionException,
                           java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • upgradeSSTables

        public void upgradeSSTables​(java.io.PrintStream out,
                                    java.lang.String keyspaceName,
                                    boolean excludeCurrentVersion,
                                    int jobs,
                                    java.lang.String... tableNames)
                             throws java.io.IOException,
                                    java.util.concurrent.ExecutionException,
                                    java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • garbageCollect

        public void garbageCollect​(java.io.PrintStream out,
                                   java.lang.String tombstoneOption,
                                   int jobs,
                                   java.lang.String keyspaceName,
                                   java.lang.String... tableNames)
                            throws java.io.IOException,
                                   java.util.concurrent.ExecutionException,
                                   java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • forceUserDefinedCompaction

        public void forceUserDefinedCompaction​(java.lang.String datafiles)
                                        throws java.io.IOException,
                                               java.util.concurrent.ExecutionException,
                                               java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • forceKeyspaceCompaction

        public void forceKeyspaceCompaction​(boolean splitOutput,
                                            java.lang.String keyspaceName,
                                            java.lang.String... tableNames)
                                     throws java.io.IOException,
                                            java.util.concurrent.ExecutionException,
                                            java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • relocateSSTables

        public void relocateSSTables​(int jobs,
                                     java.lang.String keyspace,
                                     java.lang.String[] cfnames)
                              throws java.io.IOException,
                                     java.util.concurrent.ExecutionException,
                                     java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • forceKeyspaceCompactionForTokenRange

        public void forceKeyspaceCompactionForTokenRange​(java.lang.String keyspaceName,
                                                         java.lang.String startToken,
                                                         java.lang.String endToken,
                                                         java.lang.String... tableNames)
                                                  throws java.io.IOException,
                                                         java.util.concurrent.ExecutionException,
                                                         java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • forceKeyspaceFlush

        public void forceKeyspaceFlush​(java.lang.String keyspaceName,
                                       java.lang.String... tableNames)
                                throws java.io.IOException,
                                       java.util.concurrent.ExecutionException,
                                       java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.util.concurrent.ExecutionException
        java.lang.InterruptedException
      • getKeyspaceReplicationInfo

        public java.lang.String getKeyspaceReplicationInfo​(java.lang.String keyspaceName)
      • repairAsync

        public void repairAsync​(java.io.PrintStream out,
                                java.lang.String keyspace,
                                java.util.Map<java.lang.String,​java.lang.String> options)
                         throws java.io.IOException
        Throws:
        java.io.IOException
      • getPartitionSample

        public java.util.Map<java.lang.String,​java.util.List<javax.management.openmbean.CompositeData>> getPartitionSample​(int capacity,
                                                                                                                                 int durationMillis,
                                                                                                                                 int count,
                                                                                                                                 java.util.List<java.lang.String> samplers)
                                                                                                                          throws javax.management.openmbean.OpenDataException
        Throws:
        javax.management.openmbean.OpenDataException
      • getPartitionSample

        public java.util.Map<java.lang.String,​java.util.List<javax.management.openmbean.CompositeData>> getPartitionSample​(java.lang.String ks,
                                                                                                                                 java.lang.String cf,
                                                                                                                                 int capacity,
                                                                                                                                 int durationMillis,
                                                                                                                                 int count,
                                                                                                                                 java.util.List<java.lang.String> samplers)
                                                                                                                          throws javax.management.openmbean.OpenDataException
        Throws:
        javax.management.openmbean.OpenDataException
      • getDroppableTombstoneRatio

        public double getDroppableTombstoneRatio​(java.lang.String keyspace,
                                                 java.lang.String table)
      • invalidateCounterCache

        public void invalidateCounterCache()
      • invalidateKeyCache

        public void invalidateKeyCache()
      • invalidateRowCache

        public void invalidateRowCache()
      • drain

        public void drain()
                   throws java.io.IOException,
                          java.lang.InterruptedException,
                          java.util.concurrent.ExecutionException
        Throws:
        java.io.IOException
        java.lang.InterruptedException
        java.util.concurrent.ExecutionException
      • getTokenToEndpointMap

        public java.util.Map<java.lang.String,​java.lang.String> getTokenToEndpointMap​(boolean withPort)
      • getLiveNodes

        public java.util.List<java.lang.String> getLiveNodes​(boolean withPort)
      • getJoiningNodes

        public java.util.List<java.lang.String> getJoiningNodes​(boolean withPort)
      • getLeavingNodes

        public java.util.List<java.lang.String> getLeavingNodes​(boolean withPort)
      • getMovingNodes

        public java.util.List<java.lang.String> getMovingNodes​(boolean withPort)
      • getUnreachableNodes

        public java.util.List<java.lang.String> getUnreachableNodes​(boolean withPort)
      • getLoadMap

        public java.util.Map<java.lang.String,​java.lang.String> getLoadMap​(boolean withPort)
      • getOwnership

        public java.util.Map<java.net.InetAddress,​java.lang.Float> getOwnership()
      • getOwnershipWithPort

        public java.util.Map<java.lang.String,​java.lang.Float> getOwnershipWithPort()
      • effectiveOwnership

        public java.util.Map<java.net.InetAddress,​java.lang.Float> effectiveOwnership​(java.lang.String keyspace)
                                                                                     throws java.lang.IllegalStateException
        Throws:
        java.lang.IllegalStateException
      • effectiveOwnershipWithPort

        public java.util.Map<java.lang.String,​java.lang.Float> effectiveOwnershipWithPort​(java.lang.String keyspace)
                                                                                         throws java.lang.IllegalStateException
        Throws:
        java.lang.IllegalStateException
      • getMbeanServerConn

        public javax.management.MBeanServerConnection getMbeanServerConn()
      • getAndResetGCStats

        public double[] getAndResetGCStats()
      • getColumnFamilyStoreMBeanProxies

        public java.util.Iterator<java.util.Map.Entry<java.lang.String,​ColumnFamilyStoreMBean>> getColumnFamilyStoreMBeanProxies()
      • getTokens

        public java.util.List<java.lang.String> getTokens()
      • getTokens

        public java.util.List<java.lang.String> getTokens​(java.lang.String endpoint)
      • getLocalHostId

        public java.lang.String getLocalHostId()
      • getHostIdMap

        public java.util.Map<java.lang.String,​java.lang.String> getHostIdMap​(boolean withPort)
      • getLoadString

        public java.lang.String getLoadString()
      • getReleaseVersion

        public java.lang.String getReleaseVersion()
      • getCurrentGenerationNumber

        public int getCurrentGenerationNumber()
      • getUptime

        public long getUptime()
      • getHeapMemoryUsage

        public java.lang.management.MemoryUsage getHeapMemoryUsage()
      • getSnapshotLinksPerSecond

        public long getSnapshotLinksPerSecond()
      • setSnapshotLinksPerSecond

        public void setSnapshotLinksPerSecond​(long throttle)
      • takeSnapshot

        public void takeSnapshot​(java.lang.String snapshotName,
                                 java.lang.String table,
                                 java.util.Map<java.lang.String,​java.lang.String> options,
                                 java.lang.String... keyspaces)
                          throws java.io.IOException
        Take a snapshot of all the keyspaces, optionally specifying only a specific column family.
        Parameters:
        snapshotName - the name of the snapshot.
        table - the table to snapshot or all on null
        options - Options (skipFlush for now)
        keyspaces - the keyspaces to snapshot
        Throws:
        java.io.IOException
      • takeMultipleTableSnapshot

        public void takeMultipleTableSnapshot​(java.lang.String snapshotName,
                                              java.util.Map<java.lang.String,​java.lang.String> options,
                                              java.lang.String... tableList)
                                       throws java.io.IOException
        Take a snapshot of all column family from different keyspaces.
        Parameters:
        snapshotName - the name of the snapshot.
        options - Options (skipFlush for now)
        tableList - list of columnfamily from different keyspace in the form of ks1.cf1 ks2.cf2
        Throws:
        java.io.IOException
      • clearSnapshot

        public void clearSnapshot​(java.lang.String tag,
                                  java.lang.String... keyspaces)
                           throws java.io.IOException
        Remove all the existing snapshots.
        Throws:
        java.io.IOException
      • getSnapshotDetails

        public java.util.Map<java.lang.String,​javax.management.openmbean.TabularData> getSnapshotDetails()
      • trueSnapshotsSize

        public long trueSnapshotsSize()
      • isJoined

        public boolean isJoined()
      • isDrained

        public boolean isDrained()
      • isDraining

        public boolean isDraining()
      • isBootstrapMode

        public boolean isBootstrapMode()
      • joinRing

        public void joinRing()
                      throws java.io.IOException
        Throws:
        java.io.IOException
      • decommission

        public void decommission​(boolean force)
                          throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • move

        public void move​(java.lang.String newToken)
                  throws java.io.IOException
        Throws:
        java.io.IOException
      • removeNode

        public void removeNode​(java.lang.String token)
      • getRemovalStatus

        public java.lang.String getRemovalStatus​(boolean withPort)
      • forceRemoveCompletion

        public void forceRemoveCompletion()
      • assassinateEndpoint

        public void assassinateEndpoint​(java.lang.String address)
                                 throws java.net.UnknownHostException
        Throws:
        java.net.UnknownHostException
      • reloadSeeds

        public java.util.List<java.lang.String> reloadSeeds()
      • getSeeds

        public java.util.List<java.lang.String> getSeeds()
      • setCompactionThreshold

        public void setCompactionThreshold​(java.lang.String ks,
                                           java.lang.String cf,
                                           int minimumCompactionThreshold,
                                           int maximumCompactionThreshold)
        Set the compaction threshold
        Parameters:
        minimumCompactionThreshold - minimum compaction threshold
        maximumCompactionThreshold - maximum compaction threshold
      • disableAutoCompaction

        public void disableAutoCompaction​(java.lang.String ks,
                                          java.lang.String... tables)
                                   throws java.io.IOException
        Throws:
        java.io.IOException
      • enableAutoCompaction

        public void enableAutoCompaction​(java.lang.String ks,
                                         java.lang.String... tableNames)
                                  throws java.io.IOException
        Throws:
        java.io.IOException
      • getAutoCompactionDisabled

        public java.util.Map<java.lang.String,​java.lang.Boolean> getAutoCompactionDisabled​(java.lang.String ks,
                                                                                                 java.lang.String... tableNames)
                                                                                          throws java.io.IOException
        Throws:
        java.io.IOException
      • setIncrementalBackupsEnabled

        public void setIncrementalBackupsEnabled​(boolean enabled)
      • isIncrementalBackupsEnabled

        public boolean isIncrementalBackupsEnabled()
      • setCacheCapacities

        public void setCacheCapacities​(int keyCacheCapacity,
                                       int rowCacheCapacity,
                                       int counterCacheCapacity)
      • setCacheKeysToSave

        public void setCacheKeysToSave​(int keyCacheKeysToSave,
                                       int rowCacheKeysToSave,
                                       int counterCacheKeysToSave)
      • setHintedHandoffThrottleInKB

        public void setHintedHandoffThrottleInKB​(int throttleInKB)
      • getEndpointsWithPort

        public java.util.List<java.lang.String> getEndpointsWithPort​(java.lang.String keyspace,
                                                                     java.lang.String cf,
                                                                     java.lang.String key)
      • getEndpoints

        public java.util.List<java.net.InetAddress> getEndpoints​(java.lang.String keyspace,
                                                                 java.lang.String cf,
                                                                 java.lang.String key)
      • getSSTables

        public java.util.List<java.lang.String> getSSTables​(java.lang.String keyspace,
                                                            java.lang.String cf,
                                                            java.lang.String key,
                                                            boolean hexFormat)
      • getStreamStatus

        public java.util.Set<StreamState> getStreamStatus()
      • getOperationMode

        public java.lang.String getOperationMode()
      • isStarting

        public boolean isStarting()
      • truncate

        public void truncate​(java.lang.String keyspaceName,
                             java.lang.String tableName)
      • getEndpoint

        public java.lang.String getEndpoint()
      • getDataCenter

        public java.lang.String getDataCenter()
      • getRack

        public java.lang.String getRack()
      • getKeyspaces

        public java.util.List<java.lang.String> getKeyspaces()
      • getNonSystemKeyspaces

        public java.util.List<java.lang.String> getNonSystemKeyspaces()
      • getNonLocalStrategyKeyspaces

        public java.util.List<java.lang.String> getNonLocalStrategyKeyspaces()
      • getClusterName

        public java.lang.String getClusterName()
      • getPartitioner

        public java.lang.String getPartitioner()
      • disableHintedHandoff

        public void disableHintedHandoff()
      • enableHintedHandoff

        public void enableHintedHandoff()
      • isHandoffEnabled

        public boolean isHandoffEnabled()
      • enableHintsForDC

        public void enableHintsForDC​(java.lang.String dc)
      • disableHintsForDC

        public void disableHintsForDC​(java.lang.String dc)
      • getHintedHandoffDisabledDCs

        public java.util.Set<java.lang.String> getHintedHandoffDisabledDCs()
      • getViewBuildStatuses

        public java.util.Map<java.lang.String,​java.lang.String> getViewBuildStatuses​(java.lang.String keyspace,
                                                                                           java.lang.String view)
      • pauseHintsDelivery

        public void pauseHintsDelivery()
      • resumeHintsDelivery

        public void resumeHintsDelivery()
      • truncateHints

        public void truncateHints​(java.lang.String host)
      • truncateHints

        public void truncateHints()
      • refreshSizeEstimates

        public void refreshSizeEstimates()
      • stopNativeTransport

        public void stopNativeTransport()
      • startNativeTransport

        public void startNativeTransport()
      • isNativeTransportRunning

        public boolean isNativeTransportRunning()
      • stopGossiping

        public void stopGossiping()
      • startGossiping

        public void startGossiping()
      • isGossipRunning

        public boolean isGossipRunning()
      • stopCassandraDaemon

        public void stopCassandraDaemon()
      • isInitialized

        public boolean isInitialized()
      • setCompactionThroughput

        public void setCompactionThroughput​(int value)
      • getCompactionThroughput

        public int getCompactionThroughput()
      • setBatchlogReplayThrottle

        public void setBatchlogReplayThrottle​(int value)
      • getBatchlogReplayThrottle

        public int getBatchlogReplayThrottle()
      • setConcurrentCompactors

        public void setConcurrentCompactors​(int value)
      • getConcurrentCompactors

        public int getConcurrentCompactors()
      • setConcurrentViewBuilders

        public void setConcurrentViewBuilders​(int value)
      • getConcurrentViewBuilders

        public int getConcurrentViewBuilders()
      • setMaxHintWindow

        public void setMaxHintWindow​(int value)
      • getMaxHintWindow

        public int getMaxHintWindow()
      • getTimeout

        public long getTimeout​(java.lang.String type)
      • getStreamThroughput

        public int getStreamThroughput()
      • getInterDCStreamThroughput

        public int getInterDCStreamThroughput()
      • getTraceProbability

        public double getTraceProbability()
      • getExceptionCount

        public int getExceptionCount()
      • getDroppedMessages

        public java.util.Map<java.lang.String,​java.lang.Integer> getDroppedMessages()
      • loadNewSSTables

        @Deprecated
        public void loadNewSSTables​(java.lang.String ksName,
                                    java.lang.String cfName)
        Deprecated.
      • importNewSSTables

        public java.util.List<java.lang.String> importNewSSTables​(java.lang.String ksName,
                                                                  java.lang.String cfName,
                                                                  java.util.Set<java.lang.String> srcPaths,
                                                                  boolean resetLevel,
                                                                  boolean clearRepaired,
                                                                  boolean verifySSTables,
                                                                  boolean verifyTokens,
                                                                  boolean invalidateCaches,
                                                                  boolean extendedVerify,
                                                                  boolean copyData)
      • rebuildIndex

        public void rebuildIndex​(java.lang.String ksName,
                                 java.lang.String cfName,
                                 java.lang.String... idxNames)
      • getGossipInfo

        public java.lang.String getGossipInfo​(boolean withPort)
      • stop

        public void stop​(java.lang.String string)
      • setTimeout

        public void setTimeout​(java.lang.String type,
                               long value)
      • stopById

        public void stopById​(java.lang.String compactionId)
      • setStreamThroughput

        public void setStreamThroughput​(int value)
      • setInterDCStreamThroughput

        public void setInterDCStreamThroughput​(int value)
      • setTraceProbability

        public void setTraceProbability​(double value)
      • getSchemaVersion

        public java.lang.String getSchemaVersion()
      • describeRing

        public java.util.List<java.lang.String> describeRing​(java.lang.String keyspaceName,
                                                             boolean withPort)
                                                      throws java.io.IOException
        Throws:
        java.io.IOException
      • rebuild

        public void rebuild​(java.lang.String sourceDc,
                            java.lang.String keyspace,
                            java.lang.String tokens,
                            java.lang.String specificSources)
      • sampleKeyRange

        public java.util.List<java.lang.String> sampleKeyRange()
      • resetLocalSchema

        public void resetLocalSchema()
                              throws java.io.IOException
        Throws:
        java.io.IOException
      • reloadLocalSchema

        public void reloadLocalSchema()
      • isFailed

        public boolean isFailed()
      • failed

        public void failed()
      • getReadRepairAttempted

        public long getReadRepairAttempted()
      • getReadRepairRepairedBlocking

        public long getReadRepairRepairedBlocking()
      • getReadRepairRepairedBackground

        public long getReadRepairRepairedBackground()
      • getCacheMetric

        public java.lang.Object getCacheMetric​(java.lang.String cacheType,
                                               java.lang.String metricName)
        Retrieve cache metrics based on the cache type (KeyCache, RowCache, or CounterCache)
        Parameters:
        cacheType - KeyCach, RowCache, or CounterCache
        metricName - Capacity, Entries, HitRate, Size, Requests or Hits.
      • getThreadPoolMetric

        public java.lang.Object getThreadPoolMetric​(java.lang.String pathName,
                                                    java.lang.String poolName,
                                                    java.lang.String metricName)
      • getThreadPools

        public com.google.common.collect.Multimap<java.lang.String,​java.lang.String> getThreadPools()
        Retrieve threadpool paths and names for threadpools with metrics.
        Returns:
        Multimap from path (internal, request, etc.) to name
      • getNumberOfTables

        public int getNumberOfTables()
      • getColumnFamilyMetric

        public java.lang.Object getColumnFamilyMetric​(java.lang.String ks,
                                                      java.lang.String cf,
                                                      java.lang.String metricName)
        Retrieve ColumnFamily metrics
        Parameters:
        ks - Keyspace for which stats are to be displayed or null for the global value
        cf - ColumnFamily for which stats are to be displayed or null for the keyspace value (if ks supplied)
        metricName - View TableMetrics.
      • getCompactionMetric

        public java.lang.Object getCompactionMetric​(java.lang.String metricName)
        Retrieve Proxy metrics
        Parameters:
        metricName - CompletedTasks, PendingTasks, BytesCompacted or TotalCompactionsCompleted.
      • getClientMetric

        public java.lang.Object getClientMetric​(java.lang.String metricName)
        Retrieve Proxy metrics
        Parameters:
        metricName -
      • getStorageMetric

        public long getStorageMetric​(java.lang.String metricName)
        Retrieve Proxy metrics
        Parameters:
        metricName - Exceptions, Load, TotalHints or TotalHintsInProgress.
      • getCompactionHistory

        public javax.management.openmbean.TabularData getCompactionHistory()
      • reloadTriggers

        public void reloadTriggers()
      • setLoggingLevel

        public void setLoggingLevel​(java.lang.String classQualifier,
                                    java.lang.String level)
      • getLoggingLevels

        public java.util.Map<java.lang.String,​java.lang.String> getLoggingLevels()
      • getPid

        public long getPid()
      • resumeBootstrap

        public void resumeBootstrap​(java.io.PrintStream out)
                             throws java.io.IOException
        Throws:
        java.io.IOException
      • getMaximumPoolSizes

        public java.util.Map<java.lang.String,​java.util.List<java.lang.Integer>> getMaximumPoolSizes​(java.util.List<java.lang.String> stageNames)
      • setConcurrency

        public void setConcurrency​(java.lang.String stageName,
                                   int coreThreads,
                                   int maxConcurrency)
      • replayBatchlog

        public void replayBatchlog()
                            throws java.io.IOException
        Throws:
        java.io.IOException
      • getFailureDetectorPhilValues

        public javax.management.openmbean.TabularData getFailureDetectorPhilValues​(boolean withPort)
      • reloadSslCerts

        public void reloadSslCerts()
                            throws java.io.IOException
        Throws:
        java.io.IOException
      • clearConnectionHistory

        public void clearConnectionHistory()
      • disableAuditLog

        public void disableAuditLog()
      • enableAuditLog

        public void enableAuditLog​(java.lang.String loggerName,
                                   java.util.Map<java.lang.String,​java.lang.String> parameters,
                                   java.lang.String includedKeyspaces,
                                   java.lang.String excludedKeyspaces,
                                   java.lang.String includedCategories,
                                   java.lang.String excludedCategories,
                                   java.lang.String includedUsers,
                                   java.lang.String excludedUsers)
      • enableAuditLog

        public void enableAuditLog​(java.lang.String loggerName,
                                   java.lang.String includedKeyspaces,
                                   java.lang.String excludedKeyspaces,
                                   java.lang.String includedCategories,
                                   java.lang.String excludedCategories,
                                   java.lang.String includedUsers,
                                   java.lang.String excludedUsers)
      • enableOldProtocolVersions

        public void enableOldProtocolVersions()
      • disableOldProtocolVersions

        public void disableOldProtocolVersions()
      • enableFullQueryLogger

        public void enableFullQueryLogger​(java.lang.String path,
                                          java.lang.String rollCycle,
                                          java.lang.Boolean blocking,
                                          int maxQueueWeight,
                                          long maxLogSize,
                                          @Nullable
                                          java.lang.String archiveCommand,
                                          int maxArchiveRetries)
      • stopFullQueryLogger

        public void stopFullQueryLogger()
      • resetFullQueryLogger

        public void resetFullQueryLogger()