public class CassandraContext extends WorkerCtx implements SimpleClientProvider
| Modifier and Type | Class and Description |
|---|---|
static class |
CassandraContext.CassandraConfFactory
Simple class to make
CassandraConf from a Storm topology configuration. |
static class |
CassandraContext.ClientFactory
Simple class to make
CassandraContext.ClientFactory from a Storm topology configuration. |
| Constructor and Description |
|---|
CassandraContext()
Creates a new
CassandraContext instance. |
| Modifier and Type | Method and Description |
|---|---|
SimpleClient |
getClient(Map<String,Object> config)
Creates a new cassandra client based on the specified storm configuration.
|
getBeanfactory, getWorkerBean, getWorkerBean, registerpublic CassandraContext()
Creates a new CassandraContext instance.
public SimpleClient getClient(Map<String,Object> config)
Creates a new cassandra client based on the specified storm configuration.
getClient in interface SimpleClientProviderconfig - The configuration passed to the storm topology.SimpleClient instance.Copyright © 2021 The Apache Software Foundation. All rights reserved.