public class JdbcInsertBolt extends AbstractJdbcBolt
collector, configKey, connectionProvider, jdbcClient, queryTimeoutSecs
Constructor and Description |
---|
JdbcInsertBolt(ConnectionProvider connectionProvider,
JdbcMapper jdbcMapper) |
Modifier and Type | Method and Description |
---|---|
void |
declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) |
void |
execute(Tuple tuple) |
void |
prepare(Map map,
TopologyContext topologyContext,
OutputCollector collector) |
JdbcInsertBolt |
withInsertQuery(String insertQuery) |
JdbcInsertBolt |
withQueryTimeoutSecs(int queryTimeoutSecs) |
JdbcInsertBolt |
withTableName(String tableName) |
cleanup
getComponentConfiguration
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getComponentConfiguration
public JdbcInsertBolt(ConnectionProvider connectionProvider, JdbcMapper jdbcMapper)
public JdbcInsertBolt withTableName(String tableName)
public JdbcInsertBolt withInsertQuery(String insertQuery)
public JdbcInsertBolt withQueryTimeoutSecs(int queryTimeoutSecs)
public void prepare(Map map, TopologyContext topologyContext, OutputCollector collector)
prepare
in interface IBolt
prepare
in class AbstractJdbcBolt
public void execute(Tuple tuple)
public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.