org.apache.arrow.vector

Class TimeStampNanoTZVector

java.lang.Object

org.apache.arrow.vector.BaseValueVector

org.apache.arrow.vector.BaseFixedWidthVector

org.apache.arrow.vector.TimeStampVector

org.apache.arrow.vector.TimeStampNanoTZVector

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<ValueVector>, ElementAddressableVector, FieldVector, FixedWidthVector, ValueVector, VectorDefinitionSetter

public final class TimeStampNanoTZVector
extends TimeStampVector

TimeStampNanoTZVector implements a fixed width vector (8 bytes) of timestamp (nanosecond resolution) values which could be null. A validity buffer (bit vector) is maintained to track which elements in the vector are null.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.arrow.vector.TimeStampVector

TimeStampVector.TransferImpl

Field Summary

Fields inherited from class org.apache.arrow.vector.TimeStampVector

TYPE_WIDTH

Fields inherited from class org.apache.arrow.vector.BaseFixedWidthVector

actualValueCapacity, field, lastValueCapacity, validityBuffer, valueBuffer, valueCount

Fields inherited from class org.apache.arrow.vector.BaseValueVector

allocator, fieldReader, INITIAL_VALUE_ALLOCATION, MAX_ALLOCATION_SIZE, MAX_ALLOCATION_SIZE_PROPERTY

Constructor Summary

Constructors

Constructor and Description
TimeStampNanoTZVector(Field field, BufferAllocator allocator) Instantiate a TimeStampNanoTZVector.
TimeStampNanoTZVector(String name, BufferAllocator allocator, String timeZone) Instantiate a TimeStampNanoTZVector.
TimeStampNanoTZVector(String name, FieldType fieldType, BufferAllocator allocator) Instantiate a TimeStampNanoTZVector.

Method Summary

Modifier and Type	Method and Description
void	get(int index, NullableTimeStampNanoTZHolder holder) Get the element at the given index from the vector and sets the state in holder.
Types.MinorType	getMinorType() Get minor type for this vector.
Long	getObject(int index) Same as TimeStampVector.get(int).
protected FieldReader	getReaderImpl() Each vector has a different reader that implements the FieldReader interface.
String	getTimeZone() Get the time zone of the timestamps stored in this vector.
TransferPair	getTransferPair(Field field, BufferAllocator allocator) Construct a TransferPair comprising this and a target vector of the same type.
TransferPair	getTransferPair(String ref, BufferAllocator allocator) Construct a TransferPair comprising this and a target vector of the same type.
TransferPair	makeTransferPair(ValueVector to) Construct a TransferPair with a desired target vector of the same type.
void	set(int index, NullableTimeStampNanoTZHolder holder) Set the element at the given index to the value set in data holder.
void	set(int index, TimeStampNanoTZHolder holder) Set the element at the given index to the value set in data holder.
void	setSafe(int index, NullableTimeStampNanoTZHolder holder) Same as set(int, NullableTimeStampNanoTZHolder) except that it handles the case when index is greater than or equal to existing value capacity BaseFixedWidthVector.getValueCapacity().
void	setSafe(int index, TimeStampNanoTZHolder holder) Same as set(int, TimeStampNanoTZHolder) except that it handles the case when index is greater than or equal to existing value capacity BaseFixedWidthVector.getValueCapacity().

Methods inherited from class org.apache.arrow.vector.TimeStampVector

get, get, set, set, setSafe, setSafe, setValue

Methods inherited from class org.apache.arrow.vector.BaseFixedWidthVector

accept, allocateNew, allocateNew, allocateNewSafe, clear, close, copyFrom, copyFromSafe, decrementAllocationMonitor, getBuffers, getBufferSize, getBufferSizeFor, getChildrenFromFields, getDataBuffer, getDataBufferAddress, getDataPointer, getDataPointer, getField, getFieldBuffers, getFieldInnerVectors, getName, getNullCount, getOffsetBuffer, getOffsetBufferAddress, getTransferPair, getTransferPair, getTransferPair, getTypeWidth, getValidityBuffer, getValidityBufferAddress, getValidityBufferValueCapacity, getValueBufferValueCapacity, getValueCapacity, getValueCount, handleSafe, hashCode, hashCode, incrementAllocationMonitor, initializeChildrenFromFields, isNull, isSafe, isSet, loadFieldBuffers, reAlloc, refreshValueCapacity, reset, set, set, setIndexDefined, setInitialCapacity, setNull, setSafe, setSafe, setValueCount, splitAndTransferTo, transferTo, validateScalars, zeroVector

Methods inherited from class org.apache.arrow.vector.BaseValueVector

checkBufRefs, getAllocator, getReader, getValidityBufferSizeFromCount, iterator, releaseBuffer, toString, transferBuffer

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.arrow.vector.ValueVector

getAllocator, getReader, validate, validateFull

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Methods inherited from interface org.apache.arrow.vector.FieldVector

exportBuffer, exportCDataBuffers

Constructor Detail

TimeStampNanoTZVector

public TimeStampNanoTZVector(String name,
                             BufferAllocator allocator,
                             String timeZone)

Instantiate a TimeStampNanoTZVector. This doesn't allocate any memory for the data in vector.

Parameters:

name - name of the vector

allocator - allocator for memory management.

TimeStampNanoTZVector

public TimeStampNanoTZVector(String name,
                             FieldType fieldType,
                             BufferAllocator allocator)

Instantiate a TimeStampNanoTZVector. This doesn't allocate any memory for the data in vector.

Parameters:

name - name of the vector

fieldType - type of Field materialized by this vector

allocator - allocator for memory management.

TimeStampNanoTZVector

public TimeStampNanoTZVector(Field field,
                             BufferAllocator allocator)

Instantiate a TimeStampNanoTZVector. This doesn't allocate any memory for the data in vector.

Parameters:

field - Field materialized by this vector

allocator - allocator for memory management.

Method Detail

getReaderImpl

protected FieldReader getReaderImpl()

Description copied from class: BaseValueVector

Each vector has a different reader that implements the FieldReader interface. Overridden methods must make sure to return the correct concrete reader implementation.

Specified by:

getReaderImpl in class BaseValueVector

Returns:

Returns a lambda that initializes a reader when called.

getMinorType

public Types.MinorType getMinorType()

Get minor type for this vector. The vector holds values belonging to a particular type.

Returns:

Types.MinorType

getTimeZone

public String getTimeZone()

Get the time zone of the timestamps stored in this vector.

Returns:

the time zone of the timestamps stored in this vector.

get

public void get(int index,
                NullableTimeStampNanoTZHolder holder)

Get the element at the given index from the vector and sets the state in holder. If element at given index is null, holder.isSet will be zero.

Parameters:

index - position of element

getObject

public Long getObject(int index)

Same as TimeStampVector.get(int).

Parameters:

index - position of element

Returns:

element at given index

set

public void set(int index,
                NullableTimeStampNanoTZHolder holder)
         throws IllegalArgumentException

Set the element at the given index to the value set in data holder. If the value in holder is not indicated as set, element in the at the given index will be null.

Parameters:

index - position of element

holder - nullable data holder for value of element

Throws:

IllegalArgumentException

set

public void set(int index,
                TimeStampNanoTZHolder holder)

Set the element at the given index to the value set in data holder.

Parameters:

index - position of element

holder - data holder for value of element

setSafe

public void setSafe(int index,
                    NullableTimeStampNanoTZHolder holder)
             throws IllegalArgumentException

Same as set(int, NullableTimeStampNanoTZHolder) except that it handles the case when index is greater than or equal to existing value capacity BaseFixedWidthVector.getValueCapacity().

Parameters:

index - position of element

holder - nullable data holder for value of element

Throws:

IllegalArgumentException

setSafe

public void setSafe(int index,
                    TimeStampNanoTZHolder holder)

Same as set(int, TimeStampNanoTZHolder) except that it handles the case when index is greater than or equal to existing value capacity BaseFixedWidthVector.getValueCapacity().

Parameters:

index - position of element

holder - data holder for value of element

getTransferPair

public TransferPair getTransferPair(String ref,
                                    BufferAllocator allocator)

Construct a TransferPair comprising this and a target vector of the same type.

Specified by:

getTransferPair in interface ValueVector

Specified by:

getTransferPair in class BaseFixedWidthVector

Parameters:

ref - name of the target vector

allocator - allocator for the target vector

Returns:

TransferPair

getTransferPair

public TransferPair getTransferPair(Field field,
                                    BufferAllocator allocator)

Construct a TransferPair comprising this and a target vector of the same type.

Specified by:

getTransferPair in interface ValueVector

Specified by:

getTransferPair in class BaseFixedWidthVector

Parameters:

field - Field object used by the target vector

allocator - allocator for the target vector

Returns:

TransferPair

makeTransferPair

public TransferPair makeTransferPair(ValueVector to)

Construct a TransferPair with a desired target vector of the same type.

Parameters:

to - target vector

Returns:

TransferPair