Package com.databricks.jdbc.api.impl.arrow

Class ArrowStreamResult

java.lang.Object

com.databricks.jdbc.api.impl.arrow.ArrowStreamResult

All Implemented Interfaces:

IExecutionResult

public class ArrowStreamResult
extends Object
implements IExecutionResult

Constructor Summary

Constructors

Constructor	Description
ArrowStreamResult(TGetResultSetMetadataResp resultManifest, TRowSet resultData, boolean isInlineArrow, String parentStatementId, IDatabricksSession session)
ArrowStreamResult(TGetResultSetMetadataResp resultManifest, TRowSet resultData, boolean isInlineArrow, String statementId, IDatabricksSession session, IDatabricksHttpClient httpClient)
ArrowStreamResult(ResultManifest resultManifest, ResultData resultData, String statementId, IDatabricksSession session)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the result set and releases any in-memory chunks or data
long	getCurrentRow()	Gets the current row position, starting with 0.
Object	getObject(int columnIndex)	Get the object for given column index.
boolean	hasNext()	Returns if there is next row in the result set
boolean	next()	Moves the cursor to next row and returns true if this can be done

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrowStreamResult

public ArrowStreamResult(ResultManifest resultManifest,
                         ResultData resultData,
                         String statementId,
                         IDatabricksSession session)
                  throws DatabricksParsingException

Throws:

DatabricksParsingException

ArrowStreamResult

public ArrowStreamResult(TGetResultSetMetadataResp resultManifest,
                         TRowSet resultData,
                         boolean isInlineArrow,
                         String parentStatementId,
                         IDatabricksSession session)
                  throws DatabricksParsingException

Throws:

DatabricksParsingException

ArrowStreamResult

public ArrowStreamResult(TGetResultSetMetadataResp resultManifest,
                         TRowSet resultData,
                         boolean isInlineArrow,
                         String statementId,
                         IDatabricksSession session,
                         IDatabricksHttpClient httpClient)
                  throws DatabricksParsingException

Throws:

DatabricksParsingException

Method Detail

getObject

public Object getObject(int columnIndex)
                 throws DatabricksSQLException

Description copied from interface: IExecutionResult

Get the object for given column index. Here index starts with 0.

Specified by:

getObject in interface IExecutionResult

Parameters:

columnIndex - index of column starting with 0

Returns:

object at given index

Throws:

DatabricksSQLException - if there is any error in getting object

getCurrentRow

public long getCurrentRow()

Description copied from interface: IExecutionResult

Gets the current row position, starting with 0.

Specified by:

getCurrentRow in interface IExecutionResult

Returns:

the current row position

next

public boolean next()
             throws DatabricksSQLException

Description copied from interface: IExecutionResult

Moves the cursor to next row and returns true if this can be done

Specified by:

next in interface IExecutionResult

Returns:

true if cursor is moved at next row

Throws:

DatabricksSQLException

hasNext

public boolean hasNext()

Description copied from interface: IExecutionResult

Returns if there is next row in the result set

Specified by:

hasNext in interface IExecutionResult

close

public void close()

Description copied from interface: IExecutionResult

Closes the result set and releases any in-memory chunks or data

Specified by:

close in interface IExecutionResult