Modifier and Type | Method and Description |
---|---|
VectorSchemaRoot |
AvroToArrowVectorIterator.next()
Gets the next vector.
|
Modifier and Type | Method and Description |
---|---|
VectorSchemaRoot |
ArrowVectorIterator.next()
Gets the next vector.
|
Modifier and Type | Method and Description |
---|---|
static JdbcParameterBinder.Builder |
JdbcParameterBinder.builder(PreparedStatement statement,
VectorSchemaRoot root)
Initialize a binder with a builder.
|
static void |
JdbcToArrowUtils.jdbcToArrowVectors(ResultSet rs,
VectorSchemaRoot root,
Calendar calendar)
Iterate the given JDBC
ResultSet object to fetch the data and transpose it to populate
the given Arrow Vector objects. |
static void |
JdbcToArrowUtils.jdbcToArrowVectors(ResultSet rs,
VectorSchemaRoot root,
JdbcToArrowConfig config)
Iterate the given JDBC
ResultSet object to fetch the data and transpose it to populate
the given Arrow Vector objects. |
Modifier and Type | Method and Description |
---|---|
void |
CompositeJdbcConsumer.resetVectorSchemaRoot(VectorSchemaRoot root)
Reset inner consumers through vectors in the vector schema root.
|
Modifier and Type | Method and Description |
---|---|
void |
CompositeAvroConsumer.resetConsumerVectors(VectorSchemaRoot root)
Reset vector of consumers with the given
VectorSchemaRoot . |
Modifier and Type | Method and Description |
---|---|
static ArrowFlightJdbcVectorSchemaRootResultSet |
ArrowFlightJdbcVectorSchemaRootResultSet.fromVectorSchemaRoot(VectorSchemaRoot vectorSchemaRoot)
Instantiate a ResultSet backed up by given VectorSchemaRoot.
|
Constructor and Description |
---|
ArrowFlightJdbcCursor(VectorSchemaRoot root) |
Modifier and Type | Method and Description |
---|---|
VectorSchemaRoot |
VectorSchemaRootTransformer.transform(VectorSchemaRoot originalRoot,
VectorSchemaRoot transformedRoot) |
Modifier and Type | Method and Description |
---|---|
VectorSchemaRoot |
VectorSchemaRootTransformer.transform(VectorSchemaRoot originalRoot,
VectorSchemaRoot transformedRoot) |
Modifier and Type | Method and Description |
---|---|
VectorSchemaRoot |
FlightStream.getRoot()
Get the current vector data from the stream.
|
Modifier and Type | Method and Description |
---|---|
default void |
OutboundStreamListener.start(VectorSchemaRoot root)
Start sending data, using the schema of the given
VectorSchemaRoot . |
default void |
OutboundStreamListener.start(VectorSchemaRoot root,
DictionaryProvider dictionaries)
Start sending data, using the schema of the given
VectorSchemaRoot . |
void |
OutboundStreamListener.start(VectorSchemaRoot root,
DictionaryProvider dictionaries,
IpcOption option)
Start sending data, using the schema of the given
VectorSchemaRoot . |
FlightClient.ClientStreamListener |
FlightClient.startPut(FlightDescriptor descriptor,
VectorSchemaRoot root,
DictionaryProvider provider,
FlightClient.PutListener metadataListener,
CallOption... options)
Create or append a descriptor with another stream.
|
FlightClient.ClientStreamListener |
FlightClient.startPut(FlightDescriptor descriptor,
VectorSchemaRoot root,
FlightClient.PutListener metadataListener,
CallOption... options)
Create or append a descriptor with another stream.
|
Modifier and Type | Method and Description |
---|---|
void |
FlightSqlClient.PreparedStatement.setParameters(VectorSchemaRoot parameterBindingRoot)
Set the
FlightSqlClient.PreparedStatement.parameterBindingRoot containing the parameter binding from a FlightSqlClient.PreparedStatement
operation. |
Modifier and Type | Method and Description |
---|---|
VectorSchemaRoot |
VectorSchemaRoot.addVector(int index,
FieldVector vector)
Add vector to the record batch, producing a new VectorSchemaRoot.
|
static VectorSchemaRoot |
VectorSchemaRoot.create(Schema schema,
BufferAllocator allocator)
Creates a new set of empty vectors corresponding to the given schema.
|
static VectorSchemaRoot |
VectorSchemaRoot.of(FieldVector... vectors)
Constructs a new instance from vectors.
|
VectorSchemaRoot |
VectorSchemaRoot.removeVector(int index)
Remove vector from the record batch, producing a new VectorSchemaRoot.
|
VectorSchemaRoot |
VectorSchemaRoot.slice(int index)
Slice this root from desired index.
|
VectorSchemaRoot |
VectorSchemaRoot.slice(int index,
int length)
Slice this root at desired index and length.
|
Modifier and Type | Method and Description |
---|---|
boolean |
VectorSchemaRoot.approxEquals(VectorSchemaRoot other)
Determine if two VectorSchemaRoots are approximately equal using default functions to
calculate difference between float/double values.
|
boolean |
VectorSchemaRoot.approxEquals(VectorSchemaRoot other,
VectorValueEqualizer<Float4Vector> floatDiffFunction,
VectorValueEqualizer<Float8Vector> doubleDiffFunction)
Determine if two VectorSchemaRoots are approximately equal using the given functions to
calculate difference between float/double values.
|
boolean |
VectorSchemaRoot.equals(VectorSchemaRoot other)
Determine if two VectorSchemaRoots are exactly equal.
|
Constructor and Description |
---|
VectorLoader(VectorSchemaRoot root)
Construct with a root to load and will create children in root based on schema.
|
VectorLoader(VectorSchemaRoot root,
CompressionCodec.Factory factory)
Construct with a root to load and will create children in root based on schema.
|
VectorUnloader(VectorSchemaRoot root)
Constructs a new instance of the given set of vectors.
|
VectorUnloader(VectorSchemaRoot root,
boolean includeNullCount,
boolean alignBuffers)
Constructs a new instance.
|
VectorUnloader(VectorSchemaRoot root,
boolean includeNullCount,
CompressionCodec codec,
boolean alignBuffers)
Constructs a new instance.
|
Modifier and Type | Method and Description |
---|---|
VectorSchemaRoot |
ArrowReader.getVectorSchemaRoot()
Returns the vector schema root.
|
VectorSchemaRoot |
JsonFileReader.read()
Returns the next record batch from the file.
|
Modifier and Type | Method and Description |
---|---|
boolean |
JsonFileReader.read(VectorSchemaRoot root)
Reads the next record batch from the file into
root . |
void |
JsonFileWriter.write(VectorSchemaRoot recordBatch)
Writes the record batch to the JSON file.
|
Modifier and Type | Method and Description |
---|---|
VectorSchemaRoot |
BaseTable.toVectorSchemaRoot()
Returns a new VectorSchemaRoot with the data and schema from this table.
|
Constructor and Description |
---|
Table(VectorSchemaRoot vsr)
Constructs a new instance containing the data from the argument.
|
Modifier and Type | Method and Description |
---|---|
static void |
VectorSchemaRootAppender.append(boolean checkSchema,
VectorSchemaRoot targetRoot,
VectorSchemaRoot... rootsToAppend)
Appends a number of
VectorSchemaRoot s. |
static void |
VectorSchemaRootAppender.append(boolean checkSchema,
VectorSchemaRoot targetRoot,
VectorSchemaRoot... rootsToAppend)
Appends a number of
VectorSchemaRoot s. |
static void |
VectorSchemaRootAppender.append(VectorSchemaRoot targetRoot,
VectorSchemaRoot... rootsToAppend)
Appends a number of
VectorSchemaRoot s. |
static void |
VectorSchemaRootAppender.append(VectorSchemaRoot targetRoot,
VectorSchemaRoot... rootsToAppend)
Appends a number of
VectorSchemaRoot s. |
static void |
Validator.compareVectorSchemaRoot(VectorSchemaRoot root1,
VectorSchemaRoot root2)
Validate two arrow vectorSchemaRoot are equal.
|
static void |
ValueVectorUtility.ensureCapacity(VectorSchemaRoot root,
int targetCapacity)
Ensure capacity for BaseFixedWidthVector.
|
static void |
ValueVectorUtility.preAllocate(VectorSchemaRoot root,
int targetSize)
Pre allocate memory for BaseFixedWidthVector.
|
static void |
ValueVectorUtility.validate(VectorSchemaRoot root)
Utility to validate vector schema root in O(1) time.
|
static void |
ValueVectorUtility.validateFull(VectorSchemaRoot root)
Utility to validate vector in O(n) time, where n is the value count.
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.