Package | Description |
---|---|
org.apache.storm.cassandra | |
org.apache.storm.cassandra.bolt | |
org.apache.storm.cassandra.client | |
org.apache.storm.cassandra.client.impl |
Modifier and Type | Method and Description |
---|---|
SimpleClient |
CassandraContext.getClient(Map<String,Object> config)
Creates a new cassandra client based on the specified storm configuration.
|
protected SimpleClient |
CassandraContext.ClientFactory.make(Map<String,Object> topoConf)
Return a new instance of T.
|
Modifier and Type | Field and Description |
---|---|
protected SimpleClient |
BaseCassandraBolt.client |
Modifier and Type | Method and Description |
---|---|
SimpleClient |
SimpleClientProvider.getClient(Map<String,Object> config)
Creates a new cassandra client based on the specified storm configuration.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultClient
Simple class to wrap cassandra
Cluster instance. |
Copyright © 2022 The Apache Software Foundation. All rights reserved.