public class ClusterFactory extends BaseBeanFactory<com.datastax.driver.core.Cluster>
Default interface to build cassandra Cluster from the a Storm Topology configuration.
context, instance| Constructor and Description |
|---|
ClusterFactory() |
| 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.
|
get, newInstance, setStormContextprotected com.datastax.driver.core.Cluster make(Map<String,Object> topoConf)
Creates a new Cluster based on the specified configuration.
make in class BaseBeanFactory<com.datastax.driver.core.Cluster>topoConf - the storm configuration.Cluster instance.Copyright © 2021 The Apache Software Foundation. All rights reserved.