Class TimeVectorAccessor
- java.lang.Object
-
- com.salesforce.datacloud.jdbc.core.accessor.QueryJDBCAccessor
-
- com.salesforce.datacloud.jdbc.core.accessor.impl.TimeVectorAccessor
-
- All Implemented Interfaces:
org.apache.calcite.avatica.util.Cursor.Accessor
public class TimeVectorAccessor extends QueryJDBCAccessor
-
-
Field Summary
-
Fields inherited from class com.salesforce.datacloud.jdbc.core.accessor.QueryJDBCAccessor
wasNull, wasNullConsumer
-
-
Constructor Summary
Constructors Constructor Description TimeVectorAccessor(org.apache.arrow.vector.TimeMicroVector vector, IntSupplier currentRowSupplier, QueryJDBCAccessorFactory.WasNullConsumer setCursorWasNull)TimeVectorAccessor(org.apache.arrow.vector.TimeMilliVector vector, IntSupplier currentRowSupplier, QueryJDBCAccessorFactory.WasNullConsumer setCursorWasNull)TimeVectorAccessor(org.apache.arrow.vector.TimeNanoVector vector, IntSupplier currentRowSupplier, QueryJDBCAccessorFactory.WasNullConsumer setCursorWasNull)TimeVectorAccessor(org.apache.arrow.vector.TimeSecVector vector, IntSupplier currentRowSupplier, QueryJDBCAccessorFactory.WasNullConsumer setCursorWasNull)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description ObjectgetObject()Class<?>getObjectClass()StringgetString()TimegetTime(Calendar calendar)TimestampgetTimestamp(Calendar calendar)protected static TimeUnitgetTimeUnitForVector(org.apache.arrow.vector.ValueVector vector)-
Methods inherited from class com.salesforce.datacloud.jdbc.core.accessor.QueryJDBCAccessor
getArray, getAsciiStream, getBigDecimal, getBigDecimal, getBinaryStream, getBlob, getBoolean, getByte, getBytes, getCharacterStream, getClob, getCurrentRow, getDate, getDouble, getFloat, getInt, getLong, getNCharacterStream, getNClob, getNString, getObject, getObject, getRef, getShort, getSQLXML, getStruct, getUnicodeStream, getURL, wasNull
-
-
-
-
Constructor Detail
-
TimeVectorAccessor
public TimeVectorAccessor(org.apache.arrow.vector.TimeNanoVector vector, IntSupplier currentRowSupplier, QueryJDBCAccessorFactory.WasNullConsumer setCursorWasNull) throws SQLException- Throws:
SQLException
-
TimeVectorAccessor
public TimeVectorAccessor(org.apache.arrow.vector.TimeMicroVector vector, IntSupplier currentRowSupplier, QueryJDBCAccessorFactory.WasNullConsumer setCursorWasNull) throws SQLException- Throws:
SQLException
-
TimeVectorAccessor
public TimeVectorAccessor(org.apache.arrow.vector.TimeMilliVector vector, IntSupplier currentRowSupplier, QueryJDBCAccessorFactory.WasNullConsumer setCursorWasNull) throws SQLException- Throws:
SQLException
-
TimeVectorAccessor
public TimeVectorAccessor(org.apache.arrow.vector.TimeSecVector vector, IntSupplier currentRowSupplier, QueryJDBCAccessorFactory.WasNullConsumer setCursorWasNull) throws SQLException- Throws:
SQLException
-
-
Method Detail
-
getObjectClass
public Class<?> getObjectClass()
- Specified by:
getObjectClassin classQueryJDBCAccessor
-
getObject
public Object getObject()
- Specified by:
getObjectin interfaceorg.apache.calcite.avatica.util.Cursor.Accessor- Overrides:
getObjectin classQueryJDBCAccessor
-
getTime
public Time getTime(Calendar calendar)
- Specified by:
getTimein interfaceorg.apache.calcite.avatica.util.Cursor.Accessor- Overrides:
getTimein classQueryJDBCAccessor- Parameters:
calendar- Calendar passed in. Ignores the calendar- Returns:
- the Time relative to 00:00:00 assuming timezone is UTC
-
getTimestamp
public Timestamp getTimestamp(Calendar calendar)
- Specified by:
getTimestampin interfaceorg.apache.calcite.avatica.util.Cursor.Accessor- Overrides:
getTimestampin classQueryJDBCAccessor- Parameters:
calendar- Calendar passed in. Ignores the calendar- Returns:
- the Timestamp relative to 00:00:00 assuming timezone is UTC
-
getString
public String getString()
- Specified by:
getStringin interfaceorg.apache.calcite.avatica.util.Cursor.Accessor- Overrides:
getStringin classQueryJDBCAccessor
-
getTimeUnitForVector
protected static TimeUnit getTimeUnitForVector(org.apache.arrow.vector.ValueVector vector) throws SQLException
- Throws:
SQLException
-
-