org.apache.storm.cassandra.client

Class ClusterFactory

java.lang.Object

org.apache.storm.cassandra.context.BaseBeanFactory<com.datastax.driver.core.Cluster>

org.apache.storm.cassandra.client.ClusterFactory

All Implemented Interfaces:

Serializable, BeanFactory<com.datastax.driver.core.Cluster>

public class ClusterFactory
extends BaseBeanFactory<com.datastax.driver.core.Cluster>

Default interface to build cassandra Cluster from the a Storm Topology configuration.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.storm.cassandra.context.BaseBeanFactory

context, instance

Constructor Summary

Constructors

Constructor and Description
ClusterFactory()

Method Summary

Modifier and Type	Method and Description
protected com.datastax.driver.core.Cluster	make(Map<String,Object> topoConf) Creates a new Cluster based on the specified configuration.

Methods inherited from class org.apache.storm.cassandra.context.BaseBeanFactory

get, newInstance, setStormContext

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterFactory

public ClusterFactory()

Method Detail

make

protected com.datastax.driver.core.Cluster make(Map<String,Object> topoConf)

Creates a new Cluster based on the specified configuration.

Specified by:

make in class BaseBeanFactory<com.datastax.driver.core.Cluster>

Parameters:

topoConf - the storm configuration.

Returns:

a new a new Cluster instance.