Class JdbcLookupBolt

All Implemented Interfaces:
Serializable, IBolt, IComponent, IRichBolt

public class JdbcLookupBolt extends AbstractJdbcBolt
Basic bolt for querying from any database.
See Also:
  • Constructor Details

  • Method Details

    • withQueryTimeoutSecs

      public JdbcLookupBolt withQueryTimeoutSecs(int queryTimeoutSecs)
    • process

      protected void process(Tuple tuple)
      Description copied from class: BaseTickTupleAwareRichBolt
      Process a single non-tick tuple of input. Implementation needs to handle ack manually. More details on IBolt.execute(Tuple).
      Specified by:
      process in class BaseTickTupleAwareRichBolt
      tuple - The input tuple to be processed.
    • declareOutputFields

      public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)
      Description copied from interface: IComponent
      Declare 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 stream