Package 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	Description
PhoenixDataSource(String zkQuorum, int port, String zkPath, 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	Description
Connection	getConnection()
Connection	getConnection(String userName, String password)
Map<String,Object>	getConnectionProperties()
int	getLoginTimeout()
PrintWriter	getLogWriter()
Logger	getParentLogger()
boolean	isWrapperFor(Class<?> iface)
void	setLoginTimeout(int seconds)
void	setLogWriter(PrintWriter out)
<T> T	unwrap(Class<T> iface)

Methods inherited from class java.lang.Object

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

Constructor Details

PhoenixDataSource

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

PhoenixDataSource

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

Method Details

getConnectionProperties

public Map<String,Object> getConnectionProperties()

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