org.apache.drill.exec.store.phoenix

Class PhoenixReader

java.lang.Object

org.apache.drill.exec.store.phoenix.PhoenixReader

All Implemented Interfaces:

AutoCloseable

public class PhoenixReader
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	PhoenixReader.ArrayBigintDefn
protected static class	PhoenixReader.ArrayBooleanDefn
protected static class	PhoenixReader.ArrayDefn
protected static class	PhoenixReader.ArrayDoubleDefn
protected static class	PhoenixReader.ArrayIntegerDefn
protected static class	PhoenixReader.ArraySmallintDefn
protected static class	PhoenixReader.ArrayTinyintDefn
protected static class	PhoenixReader.ArrayVarcharDefn
protected static class	PhoenixReader.ColumnDefn
protected static class	PhoenixReader.GenericDateDefn
protected static class	PhoenixReader.GenericDefn
protected static class	PhoenixReader.GenericTimeDefn
protected static class	PhoenixReader.GenericTimestampDefn

Field Summary

Fields

Modifier and Type	Field and Description
protected static Map<Integer,TypeProtos.MinorType>	COLUMN_TYPE_MAP

Constructor Summary

Constructors

Constructor and Description
PhoenixReader(ResultSetLoader loader, PhoenixReader.ColumnDefn[] columns, ResultSet results)

Method Summary

Modifier and Type	Method and Description
void	close()
int	getBatchCount()
long	getRowCount()
RowSetLoader	getStorage()
boolean	processRow() Fetch and process one row.

Methods inherited from class java.lang.Object

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

Field Detail

COLUMN_TYPE_MAP

protected static final Map<Integer,TypeProtos.MinorType> COLUMN_TYPE_MAP

Constructor Detail

PhoenixReader

public PhoenixReader(ResultSetLoader loader,
                     PhoenixReader.ColumnDefn[] columns,
                     ResultSet results)

Method Detail

getStorage

public RowSetLoader getStorage()

getRowCount

public long getRowCount()

getBatchCount

public int getBatchCount()

processRow

public boolean processRow()
                   throws SQLException

Fetch and process one row.

Returns:

return true if one row is processed, return false if there is no next row.

Throws:

SQLException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception