org.apache.storm.cassandra.client.impl

Class DefaultClient

java.lang.Object

org.apache.storm.cassandra.client.impl.DefaultClient

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, SimpleClient

public class DefaultClient
extends Object
implements SimpleClient, Closeable, Serializable

Simple class to wrap cassandra Cluster instance.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DefaultClient(com.datastax.driver.core.Cluster cluster, String keyspace) Create a new DefaultClient instance.

Method Summary

Modifier and Type	Method and Description
void	close() Close the underlying Cluster instance.
com.datastax.driver.core.Session	connect() Creates a new session on this cluster.
Set<com.datastax.driver.core.Host>	getAllHosts()
com.datastax.driver.core.Metadata	getMetadata()
boolean	isClose() Checks whether the underlying cluster instance is closed.
protected boolean	isDisconnected() Checks whether the client is already connected to the cluster.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultClient

public DefaultClient(com.datastax.driver.core.Cluster cluster,
                     String keyspace)

Create a new DefaultClient instance.

Parameters:

cluster - a cassandra cluster client.

Method Detail

getAllHosts

public Set<com.datastax.driver.core.Host> getAllHosts()

getMetadata

public com.datastax.driver.core.Metadata getMetadata()

connect

public com.datastax.driver.core.Session connect()
                                         throws com.datastax.driver.core.exceptions.NoHostAvailableException

Creates a new session on this cluster. *

Specified by:

connect in interface SimpleClient

Returns:

a new session on this cluster.

Throws:

com.datastax.driver.core.exceptions.NoHostAvailableException - if we cannot reach any cassandra contact points.

isDisconnected

protected boolean isDisconnected()

Checks whether the client is already connected to the cluster.

close

public void close()

Close the underlying Cluster instance.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SimpleClient

isClose

public boolean isClose()

Checks whether the underlying cluster instance is closed.

Specified by:

isClose in interface SimpleClient