org.apache.cassandra.tools

Class Shuffle

java.lang.Object

org.apache.cassandra.tools.AbstractJmxClient

org.apache.cassandra.tools.Shuffle

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class Shuffle
extends AbstractJmxClient

Field Summary

Fields inherited from class org.apache.cassandra.tools.AbstractJmxClient

DEFAULT_HOST, DEFAULT_JMX_PORT, host, jmxConn, out, password, port, username

Constructor Summary

Constructors

Constructor and Description
Shuffle(java.lang.String host, int port, java.lang.String thriftHost, int thriftPort, boolean thriftFramed, java.lang.String jmxUsername, java.lang.String jmxPassword, java.lang.String thriftUsername, java.lang.String thriftPassword)

Method Summary

Methods

Modifier and Type	Method and Description
void	clear() Clear pending token relocations on all nodes.
void	disable() Disable shuffling on all nodes in the cluster.
void	enable() Enable shuffling on all nodes in the cluster.
void	ls() Print a list of pending token relocations for all nodes.
static void	main(java.lang.String[] args) Execute.
void	shuffle(boolean enable, java.lang.String onlyDc) Create and distribute a new, randomized token to endpoint mapping.

Methods inherited from class org.apache.cassandra.tools.AbstractJmxClient

addCmdOption, close, printHelp, processArguments, setOutput, write, write, writeln, writeln, writeln

Methods inherited from class java.lang.Object

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

Constructor Detail

Shuffle

public Shuffle(java.lang.String host,
       int port,
       java.lang.String thriftHost,
       int thriftPort,
       boolean thriftFramed,
       java.lang.String jmxUsername,
       java.lang.String jmxPassword,
       java.lang.String thriftUsername,
       java.lang.String thriftPassword)
        throws java.io.IOException

Throws:

java.io.IOException

Method Detail

shuffle

public void shuffle(boolean enable,
           java.lang.String onlyDc)
             throws org.apache.cassandra.tools.Shuffle.ShuffleError

Create and distribute a new, randomized token to endpoint mapping.

Throws:

ShuffleError - on handled exceptions

org.apache.cassandra.tools.Shuffle.ShuffleError

ls

public void ls()
        throws org.apache.cassandra.tools.Shuffle.ShuffleError

Print a list of pending token relocations for all nodes.

Throws:

ShuffleError

org.apache.cassandra.tools.Shuffle.ShuffleError

clear

public void clear()
           throws org.apache.cassandra.tools.Shuffle.ShuffleError

Clear pending token relocations on all nodes.

Throws:

ShuffleError

org.apache.cassandra.tools.Shuffle.ShuffleError

enable

public void enable()
            throws org.apache.cassandra.tools.Shuffle.ShuffleError

Enable shuffling on all nodes in the cluster.

Throws:

ShuffleError

org.apache.cassandra.tools.Shuffle.ShuffleError

disable

public void disable()
             throws org.apache.cassandra.tools.Shuffle.ShuffleError

Disable shuffling on all nodes in the cluster.

Throws:

ShuffleError

org.apache.cassandra.tools.Shuffle.ShuffleError

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Execute.

Parameters:

args - arguments passed on the command line

Throws:

java.lang.Exception - when face meets palm