Package | Description |
---|---|
org.apache.storm.cassandra.bolt |
Modifier and Type | Class and Description |
---|---|
class |
BatchCassandraWriterBolt |
class |
CassandraWriterBolt |
Modifier and Type | Method and Description |
---|---|
BaseCassandraBolt |
BaseCassandraBolt.withCassandraConfig(Map<String,Object> config)
Takes the given
config for creating cassandra client. |
BaseCassandraBolt |
BaseCassandraBolt.withOutputFields(Fields fields)
Configures this bolt with the given
fields as outputfields with stream id as Utils.DEFAULT_STREAM_ID . |
BaseCassandraBolt |
BaseCassandraBolt.withResultHandler(ExecutionResultHandler resultHandler) |
BaseCassandraBolt |
BaseCassandraBolt.withStreamOutputFields(String stream,
Fields fields)
Configures this bolt given
fields as outputfields for the given stream . |
Copyright © 2020 The Apache Software Foundation. All rights reserved.