org.thales.punch.libraries.storm.bolt.impl

Class JdbcHandle

java.lang.Object

org.thales.punch.libraries.storm.bolt.impl.JdbcHandle

All Implemented Interfaces:

Runnable

public class JdbcHandle
extends Object
implements Runnable

Constructor Summary

Constructors

Constructor and Description
JdbcHandle(Map<String,Object> map, int queryQueueTime) Create a JDBC handle.

Method Summary

Modifier and Type	Method and Description
void	cleanup()
org.apache.storm.jdbc.common.JdbcClient	getJdbcClient()
boolean	isEnabled()
void	run()
void	startAsync()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JdbcHandle

public JdbcHandle(Map<String,Object> map,
                  int queryQueueTime)

Create a JDBC handle. It is not started.

Parameters:

map - the hikari config map

queryQueueTime -

Method Detail

startAsync

public void startAsync()

isEnabled

public boolean isEnabled()

cleanup

public void cleanup()

getJdbcClient

public org.apache.storm.jdbc.common.JdbcClient getJdbcClient()

run

public void run()

Specified by:

run in interface Runnable