Modifier and Type | Class and Description |
---|---|
class |
BaseConsumer<V extends ValueVector>
Base class for all consumers.
|
interface |
JdbcConsumer<T extends ValueVector>
An abstraction that is used to consume values from
ResultSet . |
Modifier and Type | Field and Description |
---|---|
protected V |
BaseConsumer.vector |
Modifier and Type | Method and Description |
---|---|
void |
CompositeJdbcConsumer.resetValueVector(ValueVector vector) |
Modifier and Type | Class and Description |
---|---|
class |
VectorRunDeduplicator<V extends ValueVector>
Remove adjacent equal elements from a vector.
|
Modifier and Type | Interface and Description |
---|---|
interface |
DictionaryBuilder<V extends ValueVector>
A dictionary builder is intended for the scenario frequently encountered in practice:
the dictionary is not known a priori, so it is generated dynamically.
|
interface |
DictionaryEncoder<E extends BaseIntVector,D extends ValueVector>
A dictionary encoder translates one vector into another one based on a dictionary vector.
|
class |
LinearDictionaryEncoder<E extends BaseIntVector,D extends ValueVector>
Dictionary encoder based on linear search.
|
class |
SearchDictionaryEncoder<E extends BaseIntVector,D extends ValueVector>
Dictionary encoder based on searching.
|
class |
SearchTreeBasedDictionaryBuilder<V extends ValueVector>
This class builds the dictionary based on a binary search tree.
|
Modifier and Type | Class and Description |
---|---|
class |
VectorRank<V extends ValueVector>
Utility for calculating ranks of vector elements.
|
Modifier and Type | Class and Description |
---|---|
class |
ParallelSearcher<V extends ValueVector>
Search for a value in the vector by multiple threads.
|
Modifier and Type | Method and Description |
---|---|
static <V extends ValueVector> |
VectorSearcher.binarySearch(V targetVector,
VectorValueComparator<V> comparator,
V keyVector,
int keyIndex)
Search for a particular element from the key vector in the target vector by binary search.
|
static <V extends ValueVector> |
VectorRangeSearcher.getFirstMatch(V targetVector,
VectorValueComparator<V> comparator,
V keyVector,
int keyIndex)
Search for the first occurrence of an element.
|
static <V extends ValueVector> |
VectorRangeSearcher.getLastMatch(V targetVector,
VectorValueComparator<V> comparator,
V keyVector,
int keyIndex)
Search for the last occurrence of an element.
|
static <V extends ValueVector> |
VectorSearcher.linearSearch(V targetVector,
VectorValueComparator<V> comparator,
V keyVector,
int keyIndex)
Search for a particular element from the key vector in the target vector by traversing the vector in sequence.
|
Modifier and Type | Class and Description |
---|---|
static class |
DefaultVectorComparators.FixedSizeListComparator<T extends ValueVector>
Default comparator for
RepeatedValueVector . |
static class |
DefaultVectorComparators.RepeatedValueComparator<T extends ValueVector>
Default comparator for
RepeatedValueVector . |
class |
GeneralOutOfPlaceVectorSorter<V extends ValueVector>
An out-of-place sorter for vectors of arbitrary type, with time complexity O(n*log(n)).
|
class |
IndexSorter<V extends ValueVector>
Sorter for the indices of a vector.
|
interface |
InPlaceVectorSorter<V extends ValueVector>
Basic interface for sorting a vector in-place.
|
interface |
OutOfPlaceVectorSorter<V extends ValueVector>
Basic interface for sorting a vector out-of-place.
|
class |
StableVectorComparator<V extends ValueVector>
Stable sorter.
|
class |
VectorValueComparator<V extends ValueVector>
Compare two values at the given indices in the vectors.
|
Modifier and Type | Field and Description |
---|---|
protected V |
VectorValueComparator.vector1
The first vector to compare.
|
protected V |
VectorValueComparator.vector2
The second vector to compare.
|
Modifier and Type | Method and Description |
---|---|
static <T extends ValueVector> |
DefaultVectorComparators.createDefaultComparator(T vector)
Create the default comparator for the vector.
|
static <T extends ValueVector> |
IndexSorter.partition(int low,
int high,
IntVector indices,
VectorValueComparator<T> comparator)
Partition a range of values in a vector into two parts, with elements in one part smaller than
elements from the other part.
|
Modifier and Type | Method and Description |
---|---|
VectorValueComparator<ValueVector> |
CompositeVectorComparator.createNew() |
Modifier and Type | Method and Description |
---|---|
static ArrowFlightJdbcAccessor |
ArrowFlightJdbcAccessorFactory.createAccessor(ValueVector vector,
IntSupplier getCurrentRow,
ArrowFlightJdbcAccessorFactory.WasNullConsumer setCursorWasNull)
Create an accessor according to its type.
|
Modifier and Type | Method and Description |
---|---|
protected static TimeUnit |
ArrowFlightJdbcDateVectorAccessor.getTimeUnitForVector(ValueVector vector) |
protected static TimeUnit |
ArrowFlightJdbcTimeVectorAccessor.getTimeUnitForVector(ValueVector vector) |
Modifier and Type | Method and Description |
---|---|
protected abstract ValueVector |
AbstractArrowFlightJdbcUnionVectorAccessor.getVectorByTypeId(byte typeId) |
protected ValueVector |
ArrowFlightJdbcDenseUnionVectorAccessor.getVectorByTypeId(byte typeId) |
protected ValueVector |
ArrowFlightJdbcUnionVectorAccessor.getVectorByTypeId(byte typeId) |
Modifier and Type | Method and Description |
---|---|
protected abstract ArrowFlightJdbcAccessor |
AbstractArrowFlightJdbcUnionVectorAccessor.createAccessorForVector(ValueVector vector) |
protected ArrowFlightJdbcAccessor |
ArrowFlightJdbcDenseUnionVectorAccessor.createAccessorForVector(ValueVector vector) |
protected ArrowFlightJdbcAccessor |
ArrowFlightJdbcUnionVectorAccessor.createAccessorForVector(ValueVector vector) |
Modifier and Type | Class and Description |
---|---|
class |
AddOrGetResult<V extends ValueVector>
Tuple class containing a vector and whether is was created.
|
class |
ExtensionTypeVector<T extends ValueVector & FieldVector>
A vector that wraps an underlying vector, used to help implement extension types.
|
Modifier and Type | Interface and Description |
---|---|
interface |
BaseIntVector
Interface for all int type vectors.
|
interface |
ElementAddressableVector
Vector for which each data element resides in a continuous memory region,
so it can be pointed to by an
ArrowBufPointer . |
interface |
FieldVector
A vector corresponding to a Field in the schema.
|
interface |
FixedWidthVector
Interface for all fixed width
ElementAddressableVector (e.g. |
interface |
FloatingPointVector
The interface for vectors with floating point values.
|
interface |
VariableWidthVector
Interface vectors that contain variable width members (e.g.
|
Modifier and Type | Class and Description |
---|---|
class |
BaseFixedWidthVector
BaseFixedWidthVector provides an abstract interface for
implementing vectors of fixed width values.
|
class |
BaseLargeVariableWidthVector
BaseLargeVariableWidthVector is a base class providing functionality for large strings/large bytes types.
|
class |
BaseValueVector
Base class for other Arrow Vector Types.
|
class |
BaseVariableWidthVector
BaseVariableWidthVector is a base class providing functionality for strings/bytes types.
|
class |
BigIntVector
BigIntVector implements a fixed width vector (8 bytes) of
integer values which could be null.
|
class |
BitVector
BitVector implements a fixed width (1 bit) vector of
boolean values which could be null.
|
class |
DateDayVector
DateDayVector implements a fixed width (4 bytes) vector of
date values which could be null.
|
class |
DateMilliVector
DateMilliVector implements a fixed width vector (8 bytes) of
date values which could be null.
|
class |
Decimal256Vector
Decimal256Vector implements a fixed width vector (32 bytes) of
decimal values which could be null.
|
class |
DecimalVector
DecimalVector implements a fixed width vector (16 bytes) of
decimal values which could be null.
|
class |
DurationVector
DurationVector implements a fixed width vector (8 bytes) of
a configurable TimeUnit granularity duration values which could be null.
|
class |
ExtensionTypeVector<T extends ValueVector & FieldVector>
A vector that wraps an underlying vector, used to help implement extension types.
|
class |
FixedSizeBinaryVector
FixedSizeBinaryVector implements a fixed width vector of
binary values which could be null.
|
class |
Float2Vector
Float2Vector implements a fixed width (2 bytes) vector of
short values which could be null.
|
class |
Float4Vector
Float4Vector implements a fixed width vector (4 bytes) of
float values which could be null.
|
class |
Float8Vector
Float8Vector implements a fixed width vector (8 bytes) of
double values which could be null.
|
class |
IntervalDayVector
IntervalDayVector implements a fixed width vector (8 bytes) of
interval (days and milliseconds) values which could be null.
|
class |
IntervalMonthDayNanoVector
IntervalMonthDayNanoVector implements a fixed width vector (16 bytes) of
interval (month, days and nanoseconds) values which could be null.
|
class |
IntervalYearVector
IntervalYearVector implements a fixed width (4 bytes) vector of
interval (years and months) values which could be null.
|
class |
IntVector
IntVector implements a fixed width (4 bytes) vector of
integer values which could be null.
|
class |
LargeVarBinaryVector
LargeVarBinaryVector implements a large variable width vector of binary
values which could be NULL.
|
class |
LargeVarCharVector
LargeVarCharVector implements a variable width vector of VARCHAR
values which could be NULL.
|
class |
NullVector
A null type vector.
|
class |
SmallIntVector
SmallIntVector implements a fixed width (2 bytes) vector of
short values which could be null.
|
class |
TimeMicroVector
TimeMicroVector implements a fixed width vector (8 bytes) of
time (microsecond resolution) values which could be null.
|
class |
TimeMilliVector
TimeMilliVector implements a fixed width (4 bytes) vector of
time (millisecond resolution) values which could be null.
|
class |
TimeNanoVector
TimeNanoVector implements a fixed width vector (8 bytes) of
time (nanosecond resolution) values which could be null.
|
class |
TimeSecVector
TimeSecVector implements a fixed width (4 bytes) vector of
time (seconds resolution) values which could be null.
|
class |
TimeStampMicroTZVector
TimeStampMicroTZVector implements a fixed width vector (8 bytes) of
timestamp (microsecond resolution) values which could be null.
|
class |
TimeStampMicroVector
TimeStampMicroVector implements a fixed width vector (8 bytes) of
timestamp (microsecond resolution) values which could be null.
|
class |
TimeStampMilliTZVector
TimeStampMilliTZVector implements a fixed width vector (8 bytes) of
timestamp (millisecond resolution) values which could be null.
|
class |
TimeStampMilliVector
TimeStampMilliVector implements a fixed width vector (8 bytes) of
timestamp (millisecond resolution) values which could be null.
|
class |
TimeStampNanoTZVector
TimeStampNanoTZVector implements a fixed width vector (8 bytes) of
timestamp (nanosecond resolution) values which could be null.
|
class |
TimeStampNanoVector
TimeStampNanoVector implements a fixed width vector (8 bytes) of
timestamp (nanosecond resolution) values which could be null.
|
class |
TimeStampSecTZVector
TimeStampSecTZVector implements a fixed width vector (8 bytes) of
timestamp (seconds resolution) values which could be null.
|
class |
TimeStampSecVector
TimeStampSecVector implements a fixed width vector (8 bytes) of
timestamp (seconds resolution) values which could be null.
|
class |
TimeStampVector
TimeStampVector is an abstract interface for fixed width vector (8 bytes)
of timestamp values which could be null.
|
class |
TinyIntVector
TinyIntVector implements a fixed width (1 bytes) vector of
byte values which could be null.
|
class |
UInt1Vector
UInt1Vector implements a fixed width (1 bytes) vector of
integer values which could be null.
|
class |
UInt2Vector
UInt2Vector implements a fixed width (2 bytes) vector of
integer values which could be null.
|
class |
UInt4Vector
UInt4Vector implements a fixed width (4 bytes) vector of
integer values which could be null.
|
class |
UInt8Vector
UInt8Vector implements a fixed width vector (8 bytes) of
integer values which could be null.
|
class |
VarBinaryVector
VarBinaryVector implements a variable width vector of binary
values which could be NULL.
|
class |
VarCharVector
VarCharVector implements a variable width vector of VARCHAR
values which could be NULL.
|
class |
ZeroVector
A zero length vector of any type.
|
Modifier and Type | Method and Description |
---|---|
Iterator<ValueVector> |
BaseValueVector.iterator() |
Iterator<ValueVector> |
NullVector.iterator() |
Iterator<ValueVector> |
ExtensionTypeVector.iterator() |
Modifier and Type | Method and Description |
---|---|
static void |
AllocationHelper.allocate(ValueVector v,
int valueCount,
int bytesPerValue)
Allocates the vector.
|
static void |
AllocationHelper.allocate(ValueVector v,
int valueCount,
int bytesPerValue,
int repeatedPerTop)
Allocates memory for a vector assuming given number of values and their width.
|
static void |
AllocationHelper.allocateNew(ValueVector v,
int valueCount)
Allocates the exact amount if v is fixed width, otherwise falls back to dynamic allocation.
|
static void |
AllocationHelper.allocatePrecomputedChildCount(ValueVector v,
int valueCount,
int bytesPerValue,
int childValCount)
Allocates memory for a vector assuming given number of values and their width.
|
static boolean |
BaseValueVector.checkBufRefs(ValueVector vv)
Checks to ensure that every buffer
vv uses
has a positive reference count, throws if this precondition
isn't met. |
void |
BaseLargeVariableWidthVector.copyFrom(int fromIndex,
int thisIndex,
ValueVector from)
Copy a cell value from a particular index in source vector to a particular
position in this vector.
|
void |
BaseValueVector.copyFrom(int fromIndex,
int thisIndex,
ValueVector from) |
void |
BaseFixedWidthVector.copyFrom(int fromIndex,
int thisIndex,
ValueVector from)
Copy a cell value from a particular index in source vector to a particular
position in this vector.
|
void |
NullVector.copyFrom(int fromIndex,
int thisIndex,
ValueVector from) |
void |
BaseVariableWidthVector.copyFrom(int fromIndex,
int thisIndex,
ValueVector from)
Copy a cell value from a particular index in source vector to a particular
position in this vector.
|
void |
BitVector.copyFrom(int fromIndex,
int thisIndex,
ValueVector from)
Copy a cell value from a particular index in source vector to a particular
position in this vector.
|
void |
ValueVector.copyFrom(int fromIndex,
int thisIndex,
ValueVector from)
Copy a cell value from a particular index in source vector to a particular
position in this vector.
|
void |
BaseLargeVariableWidthVector.copyFromSafe(int fromIndex,
int thisIndex,
ValueVector from)
Same as
BaseLargeVariableWidthVector.copyFrom(int, int, ValueVector) except that
it handles the case when the capacity of the vector needs to be expanded
before copy. |
void |
BaseValueVector.copyFromSafe(int fromIndex,
int thisIndex,
ValueVector from) |
void |
BaseFixedWidthVector.copyFromSafe(int fromIndex,
int thisIndex,
ValueVector from)
Same as
BaseFixedWidthVector.copyFrom(int, int, ValueVector) except that
it handles the case when the capacity of the vector needs to be expanded
before copy. |
void |
NullVector.copyFromSafe(int fromIndex,
int thisIndex,
ValueVector from) |
void |
BaseVariableWidthVector.copyFromSafe(int fromIndex,
int thisIndex,
ValueVector from)
Same as
BaseVariableWidthVector.copyFrom(int, int, ValueVector) except that
it handles the case when the capacity of the vector needs to be expanded
before copy. |
void |
ValueVector.copyFromSafe(int fromIndex,
int thisIndex,
ValueVector from)
Same as
copyFrom(int, int, ValueVector) except that
it handles the case when the capacity of the vector needs to be expanded
before copy. |
static void |
GenerateSampleData.generateTestData(ValueVector vector,
int valueCount)
Populates
vector with valueCount random values. |
TransferPair |
UInt1Vector.makeTransferPair(ValueVector to) |
TransferPair |
Decimal256Vector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
DateDayVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
TimeStampMicroTZVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
FixedSizeBinaryVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
IntVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
IntervalDayVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
SmallIntVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
LargeVarCharVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
ZeroVector.makeTransferPair(ValueVector target) |
TransferPair |
NullVector.makeTransferPair(ValueVector target) |
TransferPair |
IntervalMonthDayNanoVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
TimeStampNanoTZVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
Float4Vector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
TimeSecVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
BigIntVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
VarCharVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
TimeStampNanoVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
LargeVarBinaryVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
IntervalYearVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
TinyIntVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
DateMilliVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
TimeStampMilliVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
UInt2Vector.makeTransferPair(ValueVector to) |
TransferPair |
UInt8Vector.makeTransferPair(ValueVector to) |
TransferPair |
TimeStampMilliTZVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
TimeMicroVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
Float8Vector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
TimeNanoVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
DecimalVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
BitVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
TimeStampMicroVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
VarBinaryVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
DurationVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
TimeStampSecTZVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
ExtensionTypeVector.makeTransferPair(ValueVector target) |
TransferPair |
TimeStampSecVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
Float2Vector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
TransferPair |
ValueVector.makeTransferPair(ValueVector target)
Makes a new transfer pair used to transfer underlying buffers.
|
TransferPair |
UInt4Vector.makeTransferPair(ValueVector to) |
TransferPair |
TimeMilliVector.makeTransferPair(ValueVector to)
Construct a TransferPair with a desired target vector of the same type.
|
Modifier and Type | Interface and Description |
---|---|
interface |
VectorValueEqualizer<V extends ValueVector>
A function to determine if two vectors are equal at specified positions.
|
Modifier and Type | Field and Description |
---|---|
static BiFunction<ValueVector,ValueVector,Boolean> |
RangeEqualsVisitor.DEFAULT_TYPE_COMPARATOR
Default type comparator.
|
static BiFunction<ValueVector,ValueVector,Boolean> |
RangeEqualsVisitor.DEFAULT_TYPE_COMPARATOR
Default type comparator.
|
Modifier and Type | Method and Description |
---|---|
ValueVector |
RangeEqualsVisitor.getLeft() |
ValueVector |
RangeEqualsVisitor.getRight() |
Modifier and Type | Method and Description |
---|---|
protected ApproxEqualsVisitor |
ApproxEqualsVisitor.createInnerVisitor(ValueVector left,
ValueVector right,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator) |
protected RangeEqualsVisitor |
RangeEqualsVisitor.createInnerVisitor(ValueVector leftInner,
ValueVector rightInner,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator) |
boolean |
TypeEqualsVisitor.equals(ValueVector left)
Check type equals without passing IN param in VectorVisitor.
|
protected boolean |
RangeEqualsVisitor.validate(ValueVector left)
Validate the passed left vector, if it is changed, reset and check type.
|
static boolean |
VectorEqualsVisitor.vectorEquals(ValueVector left,
ValueVector right)
Checks if two vectors are equals with default type comparator.
|
static boolean |
VectorEqualsVisitor.vectorEquals(ValueVector left,
ValueVector right,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator)
Checks if two vectors are equals.
|
Modifier and Type | Method and Description |
---|---|
protected ApproxEqualsVisitor |
ApproxEqualsVisitor.createInnerVisitor(ValueVector left,
ValueVector right,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator) |
protected ApproxEqualsVisitor |
ApproxEqualsVisitor.createInnerVisitor(ValueVector left,
ValueVector right,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator) |
protected RangeEqualsVisitor |
RangeEqualsVisitor.createInnerVisitor(ValueVector leftInner,
ValueVector rightInner,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator) |
protected RangeEqualsVisitor |
RangeEqualsVisitor.createInnerVisitor(ValueVector leftInner,
ValueVector rightInner,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator) |
static boolean |
VectorEqualsVisitor.vectorEquals(ValueVector left,
ValueVector right,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator)
Checks if two vectors are equals.
|
static boolean |
VectorEqualsVisitor.vectorEquals(ValueVector left,
ValueVector right,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator)
Checks if two vectors are equals.
|
Constructor and Description |
---|
ApproxEqualsVisitor(ValueVector left,
ValueVector right)
Constructs a new instance with default tolerances.
|
ApproxEqualsVisitor(ValueVector left,
ValueVector right,
float floatEpsilon,
double doubleEpsilon)
Constructs a new instance.
|
ApproxEqualsVisitor(ValueVector left,
ValueVector right,
VectorValueEqualizer<Float4Vector> floatDiffFunction,
VectorValueEqualizer<Float8Vector> doubleDiffFunction)
Constructs a new instance.
|
ApproxEqualsVisitor(ValueVector left,
ValueVector right,
VectorValueEqualizer<Float4Vector> floatDiffFunction,
VectorValueEqualizer<Float8Vector> doubleDiffFunction,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator)
Constructs a new instance.
|
RangeEqualsVisitor(ValueVector left,
ValueVector right)
Constructs a new instance with default type comparator.
|
RangeEqualsVisitor(ValueVector left,
ValueVector right,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator)
Constructs a new instance.
|
TypeEqualsVisitor(ValueVector right)
Construct an instance.
|
TypeEqualsVisitor(ValueVector right,
boolean checkName,
boolean checkMetadata)
Construct an instance.
|
Constructor and Description |
---|
ApproxEqualsVisitor(ValueVector left,
ValueVector right,
VectorValueEqualizer<Float4Vector> floatDiffFunction,
VectorValueEqualizer<Float8Vector> doubleDiffFunction,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator)
Constructs a new instance.
|
ApproxEqualsVisitor(ValueVector left,
ValueVector right,
VectorValueEqualizer<Float4Vector> floatDiffFunction,
VectorValueEqualizer<Float8Vector> doubleDiffFunction,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator)
Constructs a new instance.
|
RangeEqualsVisitor(ValueVector left,
ValueVector right,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator)
Constructs a new instance.
|
RangeEqualsVisitor(ValueVector left,
ValueVector right,
BiFunction<ValueVector,ValueVector,Boolean> typeComparator)
Constructs a new instance.
|
Modifier and Type | Interface and Description |
---|---|
interface |
BaseListVector
Abstraction for all list type vectors.
|
interface |
RepeatedValueVector
An abstraction representing repeated value vectors.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractContainerVector
Base class for composite vectors.
|
class |
AbstractStructVector
Base class for StructVectors.
|
class |
BaseRepeatedValueVector
Base class for Vectors that contain repeated values.
|
class |
DenseUnionVector |
class |
FixedSizeListVector
A ListVector where every list value is of the same size.
|
class |
LargeListVector
A list vector contains lists of a specific type of elements.
|
class |
ListVector
A list vector contains lists of a specific type of elements.
|
class |
MapVector
A MapVector is used to store entries of key/value pairs.
|
class |
NonNullableStructVector
A struct vector that has no null values (and no validity buffer).
|
class |
StructVector
A Struct vector consists of nullability/validity buffer and children vectors
that make up the struct's fields.
|
class |
UnionVector |
Modifier and Type | Field and Description |
---|---|
ValueVector |
VectorWithOrdinal.vector |
Modifier and Type | Method and Description |
---|---|
<T extends ValueVector> |
LargeListVector.addOrGetVector(FieldType fieldType)
Initialize the data vector (and execute callback) if it hasn't already been done,
returns the data vector.
|
<T extends ValueVector> |
BaseRepeatedValueVector.addOrGetVector(FieldType fieldType)
Initialize the data vector (and execute callback) if it hasn't already been done,
returns the data vector.
|
<T extends ValueVector> |
ListVector.addOrGetVector(FieldType fieldType)
Initialize the child data vector to field type.
|
<T extends ValueVector> |
FixedSizeListVector.addOrGetVector(FieldType type) |
<T extends ValueVector> |
PromotableVector.addOrGetVector(FieldType type) |
<V extends ValueVector> |
NonNullableStructVector.getVectorById(int id,
Class<V> clazz)
Gets a child vector by ordinal position and casts to the specified class.
|
protected <T extends ValueVector> |
AbstractContainerVector.typeify(ValueVector v,
Class<T> clazz) |
Modifier and Type | Method and Description |
---|---|
protected ValueVector |
AbstractStructVector.add(String childName,
FieldType fieldType) |
ValueVector |
AbstractStructVector.getChildByOrdinal(int id)
Returns a
ValueVector corresponding to the given ordinal identifier. |
ValueVector |
RepeatedValueVector.getDataVector()
Get the data vector.
|
ValueVector |
NonNullableStructVector.StructTransferPair.getTo() |
ValueVector |
UnionVector.getVector(int index) |
ValueVector |
UnionVector.getVector(int index,
ArrowType arrowType) |
ValueVector |
NonNullableStructVector.getVectorById(int id) |
ValueVector |
DenseUnionVector.getVectorByType(byte typeId) |
ValueVector |
UnionVector.getVectorByType(int typeId) |
ValueVector |
UnionVector.getVectorByType(int typeId,
ArrowType arrowType) |
Modifier and Type | Method and Description |
---|---|
List<ValueVector> |
AbstractStructVector.getPrimitiveVectors()
Get primitive child vectors.
|
Iterator<ValueVector> |
BaseRepeatedValueVector.iterator() |
Iterator<ValueVector> |
AbstractStructVector.iterator() |
Iterator<ValueVector> |
FixedSizeListVector.iterator() |
Iterator<ValueVector> |
DenseUnionVector.iterator() |
Iterator<ValueVector> |
UnionVector.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
LargeListVector.copyFrom(int inIndex,
int outIndex,
ValueVector from)
Copy a cell value from a particular index in source vector to a particular
position in this vector.
|
void |
ListVector.copyFrom(int inIndex,
int outIndex,
ValueVector from)
Copy a cell value from a particular index in source vector to a particular
position in this vector.
|
void |
FixedSizeListVector.copyFrom(int fromIndex,
int thisIndex,
ValueVector from) |
void |
NonNullableStructVector.copyFrom(int fromIndex,
int thisIndex,
ValueVector from)
Copies the element at fromIndex in the provided vector to thisIndex.
|
void |
AbstractContainerVector.copyFrom(int fromIndex,
int thisIndex,
ValueVector from) |
void |
DenseUnionVector.copyFrom(int inIndex,
int outIndex,
ValueVector from) |
void |
UnionVector.copyFrom(int inIndex,
int outIndex,
ValueVector from) |
void |
LargeListVector.copyFromSafe(int inIndex,
int outIndex,
ValueVector from)
Same as
LargeListVector.copyFrom(int, int, ValueVector) except that
it handles the case when the capacity of the vector needs to be expanded
before copy. |
void |
ListVector.copyFromSafe(int inIndex,
int outIndex,
ValueVector from)
Same as
ListVector.copyFrom(int, int, ValueVector) except that
it handles the case when the capacity of the vector needs to be expanded
before copy. |
void |
FixedSizeListVector.copyFromSafe(int inIndex,
int outIndex,
ValueVector from) |
void |
NonNullableStructVector.copyFromSafe(int fromIndex,
int thisIndex,
ValueVector from) |
void |
AbstractContainerVector.copyFromSafe(int fromIndex,
int thisIndex,
ValueVector from) |
void |
DenseUnionVector.copyFromSafe(int inIndex,
int outIndex,
ValueVector from) |
void |
UnionVector.copyFromSafe(int inIndex,
int outIndex,
ValueVector from) |
TransferPair |
MapVector.makeTransferPair(ValueVector target) |
TransferPair |
LargeListVector.makeTransferPair(ValueVector target) |
TransferPair |
ListVector.makeTransferPair(ValueVector target) |
TransferPair |
FixedSizeListVector.makeTransferPair(ValueVector target) |
TransferPair |
NonNullableStructVector.makeTransferPair(ValueVector to) |
TransferPair |
StructVector.makeTransferPair(ValueVector to) |
TransferPair |
DenseUnionVector.makeTransferPair(ValueVector target) |
TransferPair |
UnionVector.makeTransferPair(ValueVector target) |
protected <T extends ValueVector> |
AbstractContainerVector.typeify(ValueVector v,
Class<T> clazz) |
Constructor and Description |
---|
VectorWithOrdinal(ValueVector v,
int ordinal) |
Constructor and Description |
---|
PromotableWriter(ValueVector v,
AbstractStructVector parentContainer)
Constructs a new instance.
|
PromotableWriter(ValueVector v,
AbstractStructVector parentContainer,
NullableStructWriterFactory nullableStructWriterFactory)
Constructs a new instance.
|
PromotableWriter(ValueVector v,
FixedSizeListVector fixedListVector)
Constructs a new instance.
|
PromotableWriter(ValueVector v,
FixedSizeListVector fixedListVector,
NullableStructWriterFactory nullableStructWriterFactory)
Constructs a new instance.
|
PromotableWriter(ValueVector v,
LargeListVector largeListVector)
Constructs a new instance.
|
PromotableWriter(ValueVector v,
LargeListVector largeListVector,
NullableStructWriterFactory nullableStructWriterFactory)
Constructs a new instance.
|
PromotableWriter(ValueVector v,
ListVector listVector)
Constructs a new instance.
|
PromotableWriter(ValueVector v,
ListVector listVector,
NullableStructWriterFactory nullableStructWriterFactory)
Constructs a new instance.
|
Modifier and Type | Method and Description |
---|---|
ValueVector |
DictionaryEncoder.decode(ValueVector indices)
Decodes a vector with the dictionary in this encoder.
|
static ValueVector |
DictionaryEncoder.decode(ValueVector indices,
Dictionary dictionary)
Decodes a dictionary encoded array using the provided dictionary.
|
static ValueVector |
DictionaryEncoder.decode(ValueVector indices,
Dictionary dictionary,
BufferAllocator allocator)
Decodes a dictionary encoded array using the provided dictionary.
|
ValueVector |
DictionaryEncoder.encode(ValueVector vector)
Encodes a vector with the built hash table in this encoder.
|
static ValueVector |
DictionaryEncoder.encode(ValueVector vector,
Dictionary dictionary)
Dictionary encodes a vector with a provided dictionary.
|
Modifier and Type | Method and Description |
---|---|
ValueVector |
DictionaryEncoder.decode(ValueVector indices)
Decodes a vector with the dictionary in this encoder.
|
static ValueVector |
DictionaryEncoder.decode(ValueVector indices,
Dictionary dictionary)
Decodes a dictionary encoded array using the provided dictionary.
|
static ValueVector |
DictionaryEncoder.decode(ValueVector indices,
Dictionary dictionary,
BufferAllocator allocator)
Decodes a dictionary encoded array using the provided dictionary.
|
ValueVector |
DictionaryEncoder.encode(ValueVector vector)
Encodes a vector with the built hash table in this encoder.
|
static ValueVector |
DictionaryEncoder.encode(ValueVector vector,
Dictionary dictionary)
Dictionary encodes a vector with a provided dictionary.
|
int |
DictionaryHashTable.getIndex(int indexInArray,
ValueVector toEncode)
get the corresponding dictionary index with the given index in vector which to encode.
|
Constructor and Description |
---|
DictionaryHashTable(int initialCapacity,
ValueVector dictionary,
ArrowBufHasher hasher)
Constructs an empty map with the specified initial capacity and load factor.
|
DictionaryHashTable(ValueVector dictionary) |
DictionaryHashTable(ValueVector dictionary,
ArrowBufHasher hasher) |
Modifier and Type | Method and Description |
---|---|
ValueVector |
BaseTable.decode(String vectorName,
long dictionaryId)
Returns a ValueVector containing the decoded version of the vector with the given name.
|
ValueVector |
BaseTable.encode(String vectorName,
long dictionaryId)
Returns a ValueVector containing the encoded version of the vector with the given name.
|
Modifier and Type | Method and Description |
---|---|
abstract FieldWriter |
Types.MinorType.getNewFieldWriter(ValueVector vector) |
Modifier and Type | Method and Description |
---|---|
static <V extends ValueVector> |
VectorBatchAppender.batchAppend(V targetVector,
V... vectorsToAppend)
Add value vectors in batch.
|
static <V extends ValueVector> |
ValueVectorUtility.getToString(V vector,
int start,
int end)
Get the toString() representation of vector suitable for debugging.
|
static <V extends ValueVector> |
ValueVectorUtility.getToString(V vector,
int start,
int end,
BiFunction<V,Integer,Object> valueToString)
Get the toString() representation of vector suitable for debugging.
|
Modifier and Type | Method and Description |
---|---|
ValueVector |
TransferPair.getTo() |
ValueVector |
VectorAppender.visit(BaseFixedWidthVector deltaVector,
Void value) |
ValueVector |
VectorAppender.visit(BaseLargeVariableWidthVector deltaVector,
Void value) |
ValueVector |
VectorAppender.visit(BaseVariableWidthVector deltaVector,
Void value) |
ValueVector |
VectorAppender.visit(DenseUnionVector deltaVector,
Void value) |
ValueVector |
VectorAppender.visit(ExtensionTypeVector<?> deltaVector,
Void value) |
ValueVector |
VectorAppender.visit(FixedSizeListVector deltaVector,
Void value) |
ValueVector |
VectorAppender.visit(LargeListVector deltaVector,
Void value) |
ValueVector |
VectorAppender.visit(ListVector deltaVector,
Void value) |
ValueVector |
VectorAppender.visit(NonNullableStructVector deltaVector,
Void value) |
ValueVector |
VectorAppender.visit(NullVector deltaVector,
Void value) |
ValueVector |
VectorAppender.visit(UnionVector deltaVector,
Void value) |
Modifier and Type | Method and Description |
---|---|
static <V extends ValueVector> |
VectorBatchAppender.batchAppend(V targetVector,
V... vectorsToAppend)
Add value vectors in batch.
|
static void |
ValueVectorUtility.validate(ValueVector vector)
Utility to validate vector in O(1) time.
|
static void |
ValueVectorUtility.validateFull(ValueVector vector)
Utility to validate vector in O(n) time, where n is the value count.
|
Constructor and Description |
---|
VectorAppender(ValueVector targetVector)
Constructs a new targetVector appender, with the given targetVector.
|
Copyright © 2024 The Apache Software Foundation. All rights reserved.