public class CassandraWriterBolt extends BaseCassandraBolt<Tuple>
cassandraConfConfig, client, clientProvider, outputCollector, session, stormConfig
Constructor and Description |
---|
CassandraWriterBolt(CQLStatementTupleMapper tupleMapper)
Creates a new
CassandraWriterBolt instance. |
Modifier and Type | Method and Description |
---|---|
protected AsyncResultHandler<Tuple> |
getAsyncHandler() |
protected void |
onTickTuple()
Calls by an input tick tuple.
|
protected void |
process(Tuple input)
Process a single tuple of input.
|
cleanup, declareOutputFields, execute, getAsyncExecutor, getComponentConfiguration, getMapper, getResultHandler, prepare, withOutputFields, withResultHandler, withStreamOutputFields
public CassandraWriterBolt(CQLStatementTupleMapper tupleMapper)
CassandraWriterBolt
instance.tupleMapper
- protected AsyncResultHandler<Tuple> getAsyncHandler()
getAsyncHandler
in class BaseCassandraBolt<Tuple>
protected void process(Tuple input)
process
in class BaseCassandraBolt<Tuple>
input
- The input tuple to be processed.protected void onTickTuple()
onTickTuple
in class BaseCassandraBolt<Tuple>
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.