public class JdbcLookupBolt extends AbstractJdbcBolt
Basic bolt for querying from any database.
collector, configKey, connectionProvider, jdbcClient, queryTimeoutSecs| Constructor and Description |
|---|
JdbcLookupBolt(ConnectionProvider connectionProvider,
String selectQuery,
JdbcLookupMapper jdbcLookupMapper) |
| Modifier and Type | Method and Description |
|---|---|
void |
declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)
Declare the output schema for all the streams of this topology.
|
protected void |
process(Tuple tuple)
Process a single non-tick tuple of input.
|
JdbcLookupBolt |
withQueryTimeoutSecs(int queryTimeoutSecs) |
cleanup, prepareexecute, onTickTuplegetComponentConfigurationclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetComponentConfigurationpublic JdbcLookupBolt(ConnectionProvider connectionProvider, String selectQuery, JdbcLookupMapper jdbcLookupMapper)
public JdbcLookupBolt withQueryTimeoutSecs(int queryTimeoutSecs)
protected void process(Tuple tuple)
BaseTickTupleAwareRichBoltProcess a single non-tick tuple of input. Implementation needs to handle ack manually. More details on IBolt.execute(Tuple).
process in class BaseTickTupleAwareRichBolttuple - The input tuple to be processed.public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)
IComponentDeclare the output schema for all the streams of this topology.
outputFieldsDeclarer - this is used to declare output stream ids, output fields, and whether or not each output stream is a direct streamCopyright © 2021 The Apache Software Foundation. All rights reserved.