|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.cassandra.tools.NodeProbe
public class NodeProbe
JMX client operations for Cassandra.
Constructor Summary | |
---|---|
NodeProbe(java.lang.String host)
Creates a NodeProbe using the specified JMX host and default port. |
|
NodeProbe(java.lang.String host,
int port)
Creates a NodeProbe using the specified JMX host and port. |
Method Summary | |
---|---|
void |
bootStrapNodes(java.lang.String nodeList)
Bootstrap the listed nodes with data |
void |
clearSnapshot()
Remove all the existing snapshots. |
void |
forceTableCleanup()
Trigger a cleanup of keys on all tables. |
void |
forceTableCompaction()
Trigger compaction of all tables. |
void |
forceTableFlush(java.lang.String tableName,
java.lang.String... columnFamilies)
Trigger a flush of the given CFs |
int |
getCurrentGenerationNumber()
Return the generation value for this node. |
java.lang.String |
getLiveNodes()
Retrieve the list of live nodes in the cluster, where "liveness" is determined by the failure detector of the node being queried. |
java.lang.String |
getLoadInfo()
Retrieve a textual representation of the on-disk size of data stored on this node. |
java.util.Map<Range,java.util.List<EndPoint>> |
getRangeToEndpointMap()
Retrieve a map of range to end points that describe the ring topology of a Cassandra cluster. |
java.lang.String |
getToken()
Fetch a string representation of the token. |
java.lang.String |
getUnreachableNodes()
Retrieve the list of unreachable nodes in the cluster, as determined by this node's failure detector. |
static void |
main(java.lang.String[] args)
|
void |
printCluster(java.io.PrintStream outs)
Write a list of nodes with corresponding status. |
void |
printColumnFamilyStats(java.io.PrintStream outs)
|
void |
printInfo(java.io.PrintStream outs)
Write node information. |
void |
printRing(java.io.PrintStream outs)
Write a textual representation of the Cassandra ring. |
void |
printThreadPoolStats(java.io.PrintStream outs)
Print out the size of the queues in the thread pools |
void |
takeSnapshot(java.lang.String snapshotName)
Take a snapshot of all the tables. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public NodeProbe(java.lang.String host, int port) throws java.io.IOException
host
- hostname or IP address of the JMX agentport
- TCP port of the remote JMX agent
java.io.IOException
- on connection failurespublic NodeProbe(java.lang.String host) throws java.io.IOException
host
- hostname or IP address of the JMX agent
java.io.IOException
- on connection failuresMethod Detail |
---|
public java.util.Map<Range,java.util.List<EndPoint>> getRangeToEndpointMap()
public java.lang.String getLiveNodes()
public java.lang.String getUnreachableNodes()
public java.lang.String getToken()
public int getCurrentGenerationNumber()
public java.lang.String getLoadInfo()
public void forceTableCleanup() throws java.io.IOException
java.io.IOException
public void bootStrapNodes(java.lang.String nodeList) throws java.net.UnknownHostException
nodeList
- a colon separated list of nodes to bootstrap
java.net.UnknownHostException
public void forceTableCompaction() throws java.io.IOException
java.io.IOException
public void forceTableFlush(java.lang.String tableName, java.lang.String... columnFamilies) throws java.io.IOException
java.io.IOException
public void printRing(java.io.PrintStream outs)
outs
- the stream to write topublic void printColumnFamilyStats(java.io.PrintStream outs)
public void printCluster(java.io.PrintStream outs)
outs
- the stream to write topublic void printInfo(java.io.PrintStream outs)
outs
- the stream to write topublic void takeSnapshot(java.lang.String snapshotName) throws java.io.IOException
snapshotName
- the name of the snapshot.
java.io.IOException
public void clearSnapshot() throws java.io.IOException
java.io.IOException
public void printThreadPoolStats(java.io.PrintStream outs)
outs
- Output stream to generate the output on.public static void main(java.lang.String[] args) throws java.io.IOException
args
-
java.io.IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |