org.apache.drill.exec.store.phoenix

Class PhoenixDataSource

java.lang.Object

org.apache.drill.exec.store.phoenix.PhoenixDataSource

All Implemented Interfaces:

Wrapper, CommonDataSource, DataSource

public class PhoenixDataSource
extends Object
implements DataSource

Phoenix’s Connection objects are different from most other JDBC Connections due to the underlying HBase connection. The Phoenix Connection object is designed to be a thin object that is inexpensive to create. If Phoenix Connections are reused, it is possible that the underlying HBase connection is not always left in a healthy state by the previous user. It is better to create new Phoenix Connections to ensure that you avoid any potential issues.

Constructor Summary

Constructors

Constructor and Description
PhoenixDataSource(String host, int port, String userName, Map<String,Object> connectionProperties, boolean impersonationEnabled)
PhoenixDataSource(String url, String userName, Map<String,Object> connectionProperties, boolean impersonationEnabled)

Method Summary

Modifier and Type	Method and Description
Connection	getConnection()
Connection	getConnection(String userName, String password)
Map<String,Object>	getConnectionProperties()
int	getLoginTimeout()
PrintWriter	getLogWriter()
Logger	getParentLogger()
boolean	isWrapperFor(Class<?> iface)
void	setConnectionProperties(Map<String,Object> connectionProperties)
void	setLoginTimeout(int seconds)
void	setLogWriter(PrintWriter out)
<T> T	unwrap(Class<T> iface)
Class<?>	useDriverClass() The thin-client is lightweight and better compatibility.

Methods inherited from class java.lang.Object

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

Constructor Detail

PhoenixDataSource

public PhoenixDataSource(String url,
                         String userName,
                         Map<String,Object> connectionProperties,
                         boolean impersonationEnabled)

PhoenixDataSource

public PhoenixDataSource(String host,
                         int port,
                         String userName,
                         Map<String,Object> connectionProperties,
                         boolean impersonationEnabled)

Method Detail

getConnectionProperties

public Map<String,Object> getConnectionProperties()

setConnectionProperties

public void setConnectionProperties(Map<String,Object> connectionProperties)

getLogWriter

public PrintWriter getLogWriter()

Specified by:

getLogWriter in interface CommonDataSource

setLogWriter

public void setLogWriter(PrintWriter out)

Specified by:

setLogWriter in interface CommonDataSource

setLoginTimeout

public void setLoginTimeout(int seconds)

Specified by:

setLoginTimeout in interface CommonDataSource

getLoginTimeout

public int getLoginTimeout()

Specified by:

getLoginTimeout in interface CommonDataSource

getParentLogger

public Logger getParentLogger()

Specified by:

getParentLogger in interface CommonDataSource

unwrap

public <T> T unwrap(Class<T> iface)
             throws SQLException

Specified by:

unwrap in interface Wrapper

Throws:

SQLException

isWrapperFor

public boolean isWrapperFor(Class<?> iface)

Specified by:

isWrapperFor in interface Wrapper

getConnection

public Connection getConnection()
                         throws SQLException

Specified by:

getConnection in interface DataSource

Throws:

SQLException

getConnection

public Connection getConnection(String userName,
                                String password)
                         throws SQLException

Specified by:

getConnection in interface DataSource

Throws:

SQLException

useDriverClass

public Class<?> useDriverClass()
                        throws SQLException

The thin-client is lightweight and better compatibility. Only thin-client is currently supported.

Throws:

SQLException