Java SDK Documentation  24.2.0
com.vertica.sdk.PartitionReader Class Referenceabstract
Inheritance diagram for com.vertica.sdk.PartitionReader:
Inheritance graph
Collaboration diagram for com.vertica.sdk.PartitionReader:
Collaboration graph

Public Member Functions

void addCol (ByteBuffer arg, int colstride, VerticaType dt, String colName)
 
void addCol (ByteBuffer arg, int colstride, VerticaType dt)
 
void addCol (ByteBuffer arg, ByteBuffer da, int colstride, VerticaType dt)
 
void addCol (ByteBuffer arg, ByteBuffer da, int colstride, VerticaType dt, String colName)
 
boolean checkStringUserBlockInfo (int idx)
 
boolean checkTimeUserBlockInfo (int idx)
 
boolean getBoolean (int idx)
 
ByteBuffer getColDataAreaRef (int idx)
 
ByteBuffer getColRef (int idx)
 
java.sql.Date getDate (int idx)
 
double getDouble (int idx)
 
long getLong (int idx)
 
int getNumCols ()
 
int getNumRows ()
 
BaseDataOID getProcessBlockUserInfoVectorAt (int i)
 
String getString (int idx)
 
int getStringLength (int idx)
 
int getStringLoc (int idx)
 
java.sql.Timestamp getTimestamp (int idx)
 
SizedColumnTypes getTypeMetaData ()
 
VNumeric getVNumeric (int idx)
 
VString getVString (int idx)
 
boolean isBooleanNull (int idx)
 
boolean isDateNull (int idx)
 
boolean isDoubleNull (int idx)
 
boolean isLongNull (int idx)
 
boolean isStringNull (int idx)
 
boolean isTimestampInfinite (int idx)
 
boolean isTimestampInfiniteNeg (int idx)
 
boolean isTimestampInfinitePos (int idx)
 
boolean isTimestampNull (int idx)
 
boolean next () throws UdfException, DestroyInvocation
 
abstract boolean readNextBlock () throws UdfException, DestroyInvocation
 
void resetBuffers ()
 

Public Attributes

int count
 
int index
 
int ncols
 
int nrows
 
SizedColumnTypes typeMetaData
 

Protected Member Functions

void clear ()
 
ByteBuffer getInlineColBuffer (int idx)
 

Protected Attributes

ArrayList< ByteBuffer > coldataareas
 
ArrayList< ByteBuffer > cols
 
ArrayList< Integer > colstrides
 
ArrayList< Integer > currentPos
 

Detailed Description

PartitionReader provides an iterator-based read interface over all input data in a single partition. Automatically fetches data a block-at-a-time, as needed.

Member Function Documentation

◆ addCol() [1/4]

void com.vertica.sdk.VerticaBlock.addCol ( ByteBuffer  arg,
int  colstride,
VerticaType  dt,
String  colName 
)
inherited

Add the location for reading a particular argument.

Parameters
argThe base location to find data.
colstrideThe stride between data instances.
dtThe type of input.
colNameName of the column

Referenced by com.vertica.sdk.VerticaBlock.addCol().

◆ addCol() [2/4]

void com.vertica.sdk.VerticaBlock.addCol ( ByteBuffer  arg,
int  colstride,
VerticaType  dt 
)
inherited

Add the location for reading a particular argument.

Parameters
argThe base location to find data.
colstrideThe stride between data instances.
dtThe type of input.

◆ addCol() [3/4]

void com.vertica.sdk.VerticaBlock.addCol ( ByteBuffer  arg,
ByteBuffer  da,
int  colstride,
VerticaType  dt 
)
inherited

Add the location for reading a particular argument.

Parameters
argThe base location to find data.
daThe location to find out of band string data.
colstrideThe stride between data instances.
dtThe type of input.

◆ addCol() [4/4]

void com.vertica.sdk.VerticaBlock.addCol ( ByteBuffer  arg,
ByteBuffer  da,
int  colstride,
VerticaType  dt,
String  colName 
)
inherited

Add the location for reading a particular argument.

Parameters
argThe base location to find data.
daThe location to find out of band string data.
colstrideThe stride between data instances.
dtThe type of input.
colNameName of the column

◆ getBoolean()

boolean com.vertica.sdk.BlockReader.getBoolean ( int  idx)
inherited

Get a BOOLEAN value from the input row.

Parameters
idxThe column number to retrieve from the input row.
Returns
The value of the idx'th argument, cast as a BOOLEAN.

◆ getColDataAreaRef()

ByteBuffer com.vertica.sdk.VerticaBlock.getColDataAreaRef ( int  idx)
inherited

Get the ByteBuffer that stores out of line string data (Data Area) for the idx'th argument

Parameters
idxThe column number to retrieve from the input row.
Returns
the ByteBuffer

Referenced by com.vertica.sdk.BlockReader.getVString().

◆ getColRef()

ByteBuffer com.vertica.sdk.VerticaBlock.getColRef ( int  idx)
inherited

Example: ByteBuffer a = arg_reader.getColPtr(0);

Parameters
idxThe column number to retrieve from the input row.
Returns
a ByteBuffer to the idx'th argument, containing data for the column

Referenced by com.vertica.sdk.PartitionWriter.copyFromInput(), com.vertica.sdk.BlockReader.getBoolean(), com.vertica.sdk.BlockReader.getDouble(), com.vertica.sdk.VerticaBlock.getInlineColBuffer(), com.vertica.sdk.BlockReader.getLong(), com.vertica.sdk.BlockReader.getStringLength(), com.vertica.sdk.BlockReader.getStringLoc(), com.vertica.sdk.BlockReader.getVNumeric(), com.vertica.sdk.BlockReader.getVString(), com.vertica.sdk.BlockWriter.getVStringWriter(), com.vertica.sdk.BlockReader.isBooleanNull(), com.vertica.sdk.ParamWriter.setBool(), com.vertica.sdk.BlockWriter.setBoolean(), com.vertica.sdk.BlockWriter.setBooleanNull(), com.vertica.sdk.PartitionWriter.setBooleanValue(), com.vertica.sdk.BlockWriter.setDate(), com.vertica.sdk.BlockWriter.setDateNull(), com.vertica.sdk.PartitionWriter.setDateValue(), com.vertica.sdk.BlockWriter.setDouble(), com.vertica.sdk.ParamWriter.setDouble(), com.vertica.sdk.BlockWriter.setDoubleNull(), com.vertica.sdk.PartitionWriter.setDoubleValue(), com.vertica.sdk.BlockWriter.setLong(), com.vertica.sdk.ParamWriter.setLong(), com.vertica.sdk.BlockWriter.setLongNull(), com.vertica.sdk.ParamWriter.setLongString(), com.vertica.sdk.PartitionWriter.setLongValue(), com.vertica.sdk.ParamWriter.setNumeric(), com.vertica.sdk.BlockWriter.setNumeric(), com.vertica.sdk.ParamWriter.setString(), com.vertica.sdk.BlockWriter.setString(), com.vertica.sdk.BlockWriter.setStringNull(), com.vertica.sdk.BlockWriter.setTimestamp(), com.vertica.sdk.BlockWriter.setTimestampInfiniteNeg(), com.vertica.sdk.BlockWriter.setTimestampInfinitePos(), com.vertica.sdk.BlockWriter.setTimestampNull(), and com.vertica.sdk.PartitionWriter.setTimestampValue().

◆ getDate()

java.sql.Date com.vertica.sdk.BlockReader.getDate ( int  idx)
inherited

Get a DATE value from the input row.

Parameters
idxThe column number to retrieve from the input row.
Returns
The value of the idx'th argument, cast as a DATE; null if the column is NULL.

◆ getDouble()

double com.vertica.sdk.BlockReader.getDouble ( int  idx)
inherited

Get a DOUBLE value from the input row.

Parameters
idxThe column number to retrieve from the input row.
Returns
The value of the idx'th argument, cast as a DOUBLE.

◆ getInlineColBuffer()

ByteBuffer com.vertica.sdk.VerticaBlock.getInlineColBuffer ( int  idx)
protectedinherited

Give a ByteBuffer for the given column (inline storage only). Returns a buffer with position and limit bounding the data area for a single element of that column, given the current position in the column.

Parameters
idxThe column number to retrieve from the input row.
Returns
the ByteBuffer for the column

Referenced by com.vertica.sdk.PartitionWriter.setStringBytes(), and com.vertica.sdk.PartitionWriter.setStringValue().

◆ getLong()

long com.vertica.sdk.BlockReader.getLong ( int  idx)
inherited

Get a LONG INTEGER value from the input row.

Example: long a = arg_reader.getLong(0);

Parameters
idxThe column number to retrieve from the input row.
Returns
The value of the idx'th argument, cast as a LONG INTEGER.

Referenced by com.vertica.sdk.BlockReader.getDate(), com.vertica.sdk.BlockReader.getTimestamp(), com.vertica.sdk.BlockReader.isDoubleNull(), com.vertica.sdk.BlockReader.isLongNull(), com.vertica.sdk.BlockReader.isTimestampInfiniteNeg(), and com.vertica.sdk.BlockReader.isTimestampInfinitePos().

◆ getNumCols()

int com.vertica.sdk.VerticaBlock.getNumCols ( )
inherited
Returns
the number of arguments held by this reader.

◆ getNumRows()

int com.vertica.sdk.VerticaBlock.getNumRows ( )
inherited
Returns
the number of rows held by this block.

◆ getString()

String com.vertica.sdk.BlockReader.getString ( int  idx)
inherited

Get a reference to an VARCHAR/CHAR/VARBINARY/BINARY value from the input row.

Parameters
idxThe column number to retrieve from the input row.
Returns
a reference to the idx'th argument, cast as an String.

◆ getStringLength()

int com.vertica.sdk.BlockReader.getStringLength ( int  idx)
inherited

Get length of the String from the input row

Parameters
idxThe column number to retrieve from the input row.
Returns
The length of the String in specified column.

Referenced by com.vertica.sdk.BlockReader.getVString(), and com.vertica.sdk.BlockReader.isStringNull().

◆ getStringLoc()

int com.vertica.sdk.BlockReader.getStringLoc ( int  idx)
inherited

Get 'location' of the String from the input row.

Parameters
idxThe column number to retrieve from the input row.
Returns
The location of the String in specified column. If zero, data is inlined immediately after the header, otherwise data is at offset loc within the data area.

Referenced by com.vertica.sdk.BlockReader.getVString().

◆ getTimestamp()

java.sql.Timestamp com.vertica.sdk.BlockReader.getTimestamp ( int  idx)
inherited

Get a TIMESTAMP value from the input row.

Parameters
idxThe column number to retrieve from the input row.
Returns
The value of the idx'th argument, cast as a TIMESTAMP; null if the column is NULL or represents 'infinity'.

◆ getTypeMetaData()

SizedColumnTypes com.vertica.sdk.VerticaBlock.getTypeMetaData ( )
inherited
Returns
information about the types and numbers of arguments

Referenced by com.vertica.sdk.ParamReader.getType(), com.vertica.sdk.PartitionWriter.setRowFromMap(), and com.vertica.sdk.PartitionWriter.setValue().

◆ getVNumeric()

VNumeric com.vertica.sdk.BlockReader.getVNumeric ( int  idx)
inherited

Get a reference to a VNumeric value from the input row.

Parameters
idxThe column number to retrieve from the input row.
Returns
A reference to the retrieved value cast as a Numeric.

◆ getVString()

VString com.vertica.sdk.BlockReader.getVString ( int  idx)
inherited

Get a reference from the input row to an VString value, which represents a SQL VARCHAR/CHAR/VARBINARY/BINARY value.

Parameters
idxThe column number to retrieve from the input row.
Returns
a reference to the idx'th argument, cast as an VString.

Referenced by com.vertica.sdk.BlockReader.getString().

◆ isBooleanNull()

boolean com.vertica.sdk.BlockReader.isBooleanNull ( int  idx)
inherited

Check whether a value from the input row is NULL in BOOLEAN type.

Parameters
idxThe column number to retrieve from the input row.
Returns
true if the value is NULL, false otherwise.

◆ isDateNull()

boolean com.vertica.sdk.BlockReader.isDateNull ( int  idx)
inherited

Check whether a value from the input row is NULL in DATE type.

Parameters
idxThe column number to retrieve from the input row.
Returns
true if the value is NULL, false otherwise.

Referenced by com.vertica.sdk.BlockReader.getDate().

◆ isDoubleNull()

boolean com.vertica.sdk.BlockReader.isDoubleNull ( int  idx)
inherited

Check whether a value from the input row is NULL in DOUBLE type.

Parameters
idxThe column number to retrieve from the input row.
Returns
true if the value is NULL, false otherwise.

◆ isLongNull()

boolean com.vertica.sdk.BlockReader.isLongNull ( int  idx)
inherited

Check whether a value from the input row is NULL in LONG INTERGER type.

Parameters
idxThe column number to retrieve from the input row.
Returns
true if the value is NULL, false otherwise.

Referenced by com.vertica.sdk.BlockReader.isDateNull(), and com.vertica.sdk.BlockReader.isTimestampNull().

◆ isStringNull()

boolean com.vertica.sdk.BlockReader.isStringNull ( int  idx)
inherited

Check whether a value from the input row is NULL in SQL VARCHAR/CHAR/VARBINARY/BINARY type.

Parameters
idxThe column number to retrieve from the input row.
Returns
true if the value is NULL, false otherwise.

Referenced by com.vertica.sdk.BlockReader.getString().

◆ isTimestampInfinite()

boolean com.vertica.sdk.BlockReader.isTimestampInfinite ( int  idx)
inherited

Check whether a TIMESTAMP value from the input row represents 'infinity'.

Parameters
idxThe column number to retrieve from the input row.
Returns
true if the TIMESTAMP value is '+infinity' or '-infinity', false otherwise.

Referenced by com.vertica.sdk.BlockReader.getTimestamp().

◆ isTimestampInfiniteNeg()

boolean com.vertica.sdk.BlockReader.isTimestampInfiniteNeg ( int  idx)
inherited

Check whether a TIMESTAMP value from the input row represents '-infinity'.

Parameters
idxThe column number to retrieve from the input row.
Returns
true if the TIMESTAMP value is '-infinity', false otherwise.

Referenced by com.vertica.sdk.BlockReader.isTimestampInfinite().

◆ isTimestampInfinitePos()

boolean com.vertica.sdk.BlockReader.isTimestampInfinitePos ( int  idx)
inherited

Check whether a TIMESTAMP value from the input row represents '+infinity'.

Parameters
idxThe column number to retrieve from the input row.
Returns
true if the TIMESTAMP value is '+infinity', false otherwise.

Referenced by com.vertica.sdk.BlockReader.isTimestampInfinite().

◆ isTimestampNull()

boolean com.vertica.sdk.BlockReader.isTimestampNull ( int  idx)
inherited

Check whether a value from the input row is NULL in TIMESTAMP type.

Parameters
idxThe column number to retrieve from the input row.
Returns
true if the value is NULL, false otherwise.

Referenced by com.vertica.sdk.BlockReader.getTimestamp().

◆ readNextBlock()

abstract boolean com.vertica.sdk.PartitionReader.readNextBlock ( ) throws UdfException, DestroyInvocation
abstract

Reads in the next block of data and positions cursor at the beginning.

Returns
false if there's no more input data
Exceptions
UdfExceptionUDF problem
DestroyInvocationInvocation needed to be destroyed