org.apache.hadoop.hive.ql.profiler
Class HiveProfilePublisherInfo

java.lang.Object
  org.apache.hadoop.hive.ql.profiler.HiveProfilePublisherInfo

All Implemented Interfaces:

HiveProfilerConnectionInfo

public class HiveProfilePublisherInfo
extends Object
implements HiveProfilerConnectionInfo

Constructor Summary

HiveProfilePublisherInfo(Configuration conf)

Method Summary

protected void	closeInsertStatement()
Connection	getConnection()
String	getConnectionString()
String	getDbClass()
protected PreparedStatement	getInsert(Map<String,String> stats)
protected PreparedStatement	getInsertStatement()
int	getMaxRetries()
String	getTableName()
int	getTimeout()
int	getWaitWindow()
protected void	prepareInsert()

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveProfilePublisherInfo

public HiveProfilePublisherInfo(Configuration conf)
                         throws Exception

Throws:

Exception

Method Detail

getDbClass

public String getDbClass()

Specified by:

getDbClass in interface HiveProfilerConnectionInfo

getTimeout

public int getTimeout()

Specified by:

getTimeout in interface HiveProfilerConnectionInfo

getMaxRetries

public int getMaxRetries()

Specified by:

getMaxRetries in interface HiveProfilerConnectionInfo

getWaitWindow

public int getWaitWindow()

Specified by:

getWaitWindow in interface HiveProfilerConnectionInfo

getConnectionString

public String getConnectionString()

Specified by:

getConnectionString in interface HiveProfilerConnectionInfo

getTableName

public String getTableName()

Specified by:

getTableName in interface HiveProfilerConnectionInfo

getConnection

public Connection getConnection()

Specified by:

getConnection in interface HiveProfilerConnectionInfo

getInsertStatement

protected PreparedStatement getInsertStatement()

prepareInsert

protected void prepareInsert()
                      throws SQLException

Throws:

SQLException

closeInsertStatement

protected void closeInsertStatement()
                             throws SQLException

Throws:

SQLException

getInsert

protected PreparedStatement getInsert(Map<String,String> stats)
                               throws SQLException

Throws:

SQLException