org.springframework.data.hadoop.hive

Class HiveClientFactoryBean

java.lang.Object

org.springframework.data.hadoop.hive.HiveClientFactoryBean

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<HiveClientFactory>, org.springframework.beans.factory.InitializingBean

public class HiveClientFactoryBean
extends java.lang.Object
implements org.springframework.beans.factory.FactoryBean<HiveClientFactory>, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean

FactoryBean for easy declaration and creation of a HiveClient using a JdbcTemplate. The HiveClient class is not thread-safe. We use a SingleConnectionDataSource to hold on to a connection for the duration of the client. This means that all operations while happen in the same session. This is important when setting properties on the session. Note that the caller needs to handle the object clean-up, specifically calling HiveClient.shutdown(). In general, to avoid leaks it is recommended to use the HiveTemplate.

Author:

Costin Leau, Thomas Risberg

Constructor Summary

Constructors

Constructor and Description
HiveClientFactoryBean()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
protected HiveClient	createHiveClient()
void	destroy()
HiveClientFactory	getObject()
java.lang.Class<?>	getObjectType()
int	getPhase()
boolean	isSingleton()
void	setHiveDataSource(javax.sql.DataSource dataSource) Sets the DataSource.
void	setScripts(java.util.Collection<HiveScript> scripts) Sets the scripts to execute once the client connects.

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveClientFactoryBean

public HiveClientFactoryBean()

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception

destroy

public void destroy()
             throws java.lang.Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

java.lang.Exception

getObject

public HiveClientFactory getObject()

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean<HiveClientFactory>

getObjectType

public java.lang.Class<?> getObjectType()

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<HiveClientFactory>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean<HiveClientFactory>

createHiveClient

protected HiveClient createHiveClient()

getPhase

public int getPhase()

setHiveDataSource

public void setHiveDataSource(javax.sql.DataSource dataSource)

Sets the DataSource.

Parameters:

dataSource - The DataSource.

setScripts

public void setScripts(java.util.Collection<HiveScript> scripts)

Sets the scripts to execute once the client connects.

Parameters:

scripts - The scripts to set.