Constructor and Description |
---|
ExpandableByteBuf(io.netty.buffer.ByteBuf buffer,
BufferAllocator allocator) |
NettyArrowBuf(ArrowBuf arrowBuf,
BufferAllocator bufferAllocator,
int length)
Constructs a new instance.
|
Modifier and Type | Method and Description |
---|---|
BufferAllocator |
AvroToArrowConfig.getAllocator() |
Constructor and Description |
---|
AvroToArrowConfigBuilder(BufferAllocator allocator)
Default constructor for the
AvroToArrowConfigBuilder . |
Modifier and Type | Method and Description |
---|---|
BufferAllocator |
JdbcToArrowConfig.getAllocator()
The Arrow memory allocator.
|
Modifier and Type | Method and Description |
---|---|
JdbcToArrowConfigBuilder |
JdbcToArrowConfigBuilder.setAllocator(BufferAllocator allocator)
Sets the memory allocator to use when constructing the Arrow vectors from the ResultSet.
|
static ArrowVectorIterator |
JdbcToArrow.sqlToArrowVectorIterator(ResultSet resultSet,
BufferAllocator allocator)
For the given JDBC
ResultSet , fetch the data from Relational DB and convert it to Arrow objects. |
Constructor and Description |
---|
JdbcToArrowConfigBuilder(BufferAllocator allocator,
Calendar calendar)
Constructor for the
JdbcToArrowConfigBuilder . |
JdbcToArrowConfigBuilder(BufferAllocator allocator,
Calendar calendar,
boolean includeMetadata)
Constructor for the
JdbcToArrowConfigBuilder . |
Constructor and Description |
---|
VectorRunDeduplicator(V vector,
BufferAllocator allocator)
Constructs a vector run deduplicator for a given vector.
|
Constructor and Description |
---|
VectorRank(BufferAllocator allocator)
Constructs a vector rank utility.
|
Modifier and Type | Method and Description |
---|---|
protected ArrowBuf |
ZstdCompressionCodec.doCompress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer) |
protected ArrowBuf |
Lz4CompressionCodec.doCompress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer) |
protected ArrowBuf |
ZstdCompressionCodec.doDecompress(BufferAllocator allocator,
ArrowBuf compressedBuffer) |
protected ArrowBuf |
Lz4CompressionCodec.doDecompress(BufferAllocator allocator,
ArrowBuf compressedBuffer) |
Modifier and Type | Method and Description |
---|---|
ArrowFlightSqlClientHandler.Builder |
ArrowFlightSqlClientHandler.Builder.withBufferAllocator(BufferAllocator allocator)
Sets the
BufferAllocator to use in this handler. |
Constructor and Description |
---|
AvaticaParameterBinder(ArrowFlightSqlClientHandler.PreparedStatement preparedStatement,
BufferAllocator bufferAllocator) |
Builder(Schema schema,
BufferAllocator bufferAllocator) |
Modifier and Type | Method and Description |
---|---|
FlightServer.Builder |
FlightServer.Builder.allocator(BufferAllocator allocator) |
FlightClient.Builder |
FlightClient.Builder.allocator(BufferAllocator allocator) |
static FlightClient.Builder |
FlightClient.builder(BufferAllocator allocator,
Location location)
Create a builder for a Flight client.
|
static FlightServer.Builder |
FlightServer.builder(BufferAllocator allocator,
Location location,
FlightProducer producer)
Create a builder for a Flight server.
|
static FlightClient |
FlightGrpcUtils.createFlightClient(BufferAllocator incomingAllocator,
io.grpc.ManagedChannel channel)
Creates a Flight client.
|
static FlightClient |
FlightGrpcUtils.createFlightClientWithSharedChannel(BufferAllocator incomingAllocator,
io.grpc.ManagedChannel channel)
Creates a Flight client.
|
static io.grpc.BindableService |
FlightGrpcUtils.createFlightService(BufferAllocator allocator,
FlightProducer producer,
ServerAuthHandler authHandler,
ExecutorService executor)
Creates a Flight service.
|
Constructor and Description |
---|
FlightStream(BufferAllocator allocator,
int pendingTarget,
FlightStream.Cancellable cancellable,
FlightStream.Requestor requestor)
Constructs a new instance.
|
Modifier and Type | Method and Description |
---|---|
void |
OrderedScenario.client(BufferAllocator allocator,
Location location,
FlightClient client) |
void |
FlightSqlScenario.client(BufferAllocator allocator,
Location location,
FlightClient client) |
void |
FlightSqlExtensionScenario.client(BufferAllocator allocator,
Location location,
FlightClient client) |
void |
LocationReuseConnectionScenario.client(BufferAllocator allocator,
Location location,
FlightClient client) |
FlightProducer |
OrderedScenario.producer(BufferAllocator allocator,
Location location) |
FlightProducer |
FlightSqlScenario.producer(BufferAllocator allocator,
Location location) |
FlightProducer |
LocationReuseConnectionScenario.producer(BufferAllocator allocator,
Location location) |
Constructor and Description |
---|
FlightSqlScenarioProducer(BufferAllocator allocator) |
IntegrationProducer(BufferAllocator allocator,
Location location)
Constructs a new instance.
|
Modifier and Type | Field and Description |
---|---|
BufferAllocator |
FlightSqlClientDemoApp.allocator |
Constructor and Description |
---|
FlightSqlClientDemoApp(BufferAllocator bufferAllocator) |
Modifier and Type | Class and Description |
---|---|
class |
RootAllocator
A root allocator for using direct memory for Arrow Vectors/Arrays.
|
Modifier and Type | Method and Description |
---|---|
BufferAllocator |
BufferLedger.getAllocator()
Get the buffer allocator associated with this reference manager.
|
BufferAllocator |
ReferenceManager.getAllocator()
Get the buffer allocator associated with this reference manager.
|
@Nullable BufferAllocator |
AllocationOutcomeDetails.getFailedAllocator()
Get the allocator that caused the failure.
|
BufferAllocator |
BufferLedger.getKey() |
@Nullable BufferAllocator |
BufferAllocator.getParentAllocator()
Returns the parent allocator.
|
BufferAllocator |
BufferAllocator.getRoot()
Get the root allocator of this allocator.
|
BufferAllocator |
BufferAllocator.newChildAllocator(String name,
AllocationListener listener,
long initReservation,
long maxAllocation)
Create a new child allocator.
|
BufferAllocator |
BufferAllocator.newChildAllocator(String name,
long initReservation,
long maxAllocation)
Create a new child allocator.
|
Modifier and Type | Method and Description |
---|---|
Collection<BufferAllocator> |
BufferAllocator.getChildAllocators()
Returns the set of child allocators.
|
Modifier and Type | Method and Description |
---|---|
AllocationManager |
AllocationManager.Factory.create(BufferAllocator accountingAllocator,
long size)
Create an
AllocationManager . |
default void |
AllocationListener.onChildAdded(BufferAllocator parentAllocator,
BufferAllocator childAllocator)
Called immediately after a child allocator was added to the parent allocator.
|
default void |
AllocationListener.onChildRemoved(BufferAllocator parentAllocator,
BufferAllocator childAllocator)
Called immediately after a child allocator was removed from the parent allocator.
|
ArrowBuf |
BufferLedger.retain(ArrowBuf srcBuffer,
BufferAllocator target)
Create a new ArrowBuf that is associated with an alternative allocator for the purposes of
memory ownership and accounting.
|
ArrowBuf |
ReferenceManager.retain(ArrowBuf srcBuffer,
BufferAllocator targetAllocator)
Create a new ArrowBuf that is associated with an alternative allocator for the purposes of
memory ownership and accounting.
|
BufferLedger.TransferResult |
BufferLedger.transferOwnership(ArrowBuf srcBuffer,
BufferAllocator target)
Transfer the memory accounting ownership of this ArrowBuf to another allocator.
|
OwnershipTransferResult |
ReferenceManager.transferOwnership(ArrowBuf sourceBuffer,
BufferAllocator targetAllocator)
Duplicate the memory accounting ownership of the backing allocation of the given ArrowBuf in another allocator.
|
Constructor and Description |
---|
AllocationManager(BufferAllocator accountingAllocator) |
Modifier and Type | Method and Description |
---|---|
AllocationManager |
DefaultAllocationManagerFactory.create(BufferAllocator accountingAllocator,
long size) |
Modifier and Type | Method and Description |
---|---|
BufferAllocator |
ArrowByteBufAllocator.unwrap()
Deprecated.
|
Constructor and Description |
---|
ArrowByteBufAllocator(BufferAllocator allocator)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
AllocationManager |
DefaultAllocationManagerFactory.create(BufferAllocator accountingAllocator,
long size) |
Modifier and Type | Field and Description |
---|---|
protected BufferAllocator |
BaseValueVector.allocator |
Modifier and Type | Method and Description |
---|---|
BufferAllocator |
BaseValueVector.getAllocator() |
BufferAllocator |
NullVector.getAllocator() |
BufferAllocator |
ExtensionTypeVector.getAllocator() |
BufferAllocator |
ValueVector.getAllocator() |
Modifier and Type | Method and Description |
---|---|
static VectorSchemaRoot |
VectorSchemaRoot.create(Schema schema,
BufferAllocator allocator)
Creates a new set of empty vectors corresponding to the given schema.
|
TransferPair |
BaseLargeVariableWidthVector.getTransferPair(BufferAllocator allocator)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
BaseValueVector.getTransferPair(BufferAllocator allocator) |
TransferPair |
BaseFixedWidthVector.getTransferPair(BufferAllocator allocator)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
ZeroVector.getTransferPair(BufferAllocator allocator) |
TransferPair |
NullVector.getTransferPair(BufferAllocator allocator) |
TransferPair |
BaseVariableWidthVector.getTransferPair(BufferAllocator allocator)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
ExtensionTypeVector.getTransferPair(BufferAllocator allocator) |
TransferPair |
ValueVector.getTransferPair(BufferAllocator allocator)
To transfer quota responsibility.
|
TransferPair |
UInt1Vector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
Decimal256Vector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
DateDayVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
abstract TransferPair |
BaseLargeVariableWidthVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
TimeStampMicroTZVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
FixedSizeBinaryVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
IntVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
IntervalDayVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
SmallIntVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
LargeVarCharVector.getTransferPair(Field field,
BufferAllocator allocator) |
abstract TransferPair |
BaseFixedWidthVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
NullVector.getTransferPair(Field field,
BufferAllocator allocator) |
TransferPair |
IntervalMonthDayNanoVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising of this and a target vector of
the same type.
|
TransferPair |
TimeStampNanoTZVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
Float4Vector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TimeSecVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising of this and a target vector of
the same type.
|
abstract TransferPair |
BaseVariableWidthVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
BigIntVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising of this and a target vector of
the same type.
|
TransferPair |
VarCharVector.getTransferPair(Field field,
BufferAllocator allocator) |
TransferPair |
TimeStampNanoVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
LargeVarBinaryVector.getTransferPair(Field field,
BufferAllocator allocator) |
TransferPair |
IntervalYearVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TinyIntVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
DateMilliVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TimeStampMilliVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
UInt2Vector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
UInt8Vector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TimeStampMilliTZVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TimeMicroVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
Float8Vector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TimeNanoVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
DecimalVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
BitVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TimeStampMicroVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
VarBinaryVector.getTransferPair(Field field,
BufferAllocator allocator) |
TransferPair |
DurationVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TimeStampSecTZVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising of this and a target vector of
the same type.
|
TransferPair |
ExtensionTypeVector.getTransferPair(Field field,
BufferAllocator allocator) |
TransferPair |
TimeStampSecVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
Float2Vector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
ValueVector.getTransferPair(Field field,
BufferAllocator allocator)
To transfer quota responsibility.
|
TransferPair |
UInt4Vector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TimeMilliVector.getTransferPair(Field field,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
BaseLargeVariableWidthVector.getTransferPair(Field field,
BufferAllocator allocator,
CallBack callBack)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
BaseFixedWidthVector.getTransferPair(Field field,
BufferAllocator allocator,
CallBack callBack)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
NullVector.getTransferPair(Field field,
BufferAllocator allocator,
CallBack callBack) |
TransferPair |
BaseVariableWidthVector.getTransferPair(Field field,
BufferAllocator allocator,
CallBack callBack)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
ExtensionTypeVector.getTransferPair(Field field,
BufferAllocator allocator,
CallBack callBack) |
TransferPair |
ValueVector.getTransferPair(Field field,
BufferAllocator allocator,
CallBack callBack)
To transfer quota responsibility.
|
TransferPair |
UInt1Vector.getTransferPair(String ref,
BufferAllocator allocator) |
TransferPair |
Decimal256Vector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
DateDayVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
abstract TransferPair |
BaseLargeVariableWidthVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
TimeStampMicroTZVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
FixedSizeBinaryVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
IntVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
IntervalDayVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
SmallIntVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
LargeVarCharVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising of this and a target vector of
the same type.
|
abstract TransferPair |
BaseFixedWidthVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
ZeroVector.getTransferPair(String ref,
BufferAllocator allocator) |
TransferPair |
NullVector.getTransferPair(String ref,
BufferAllocator allocator) |
TransferPair |
IntervalMonthDayNanoVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TimeStampNanoTZVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
Float4Vector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TimeSecVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
abstract TransferPair |
BaseVariableWidthVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
BigIntVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
VarCharVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising of this and a target vector of
the same type.
|
TransferPair |
TimeStampNanoVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
LargeVarBinaryVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising of this and a target vector of
the same type.
|
TransferPair |
IntervalYearVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TinyIntVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
DateMilliVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TimeStampMilliVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
UInt2Vector.getTransferPair(String ref,
BufferAllocator allocator) |
TransferPair |
UInt8Vector.getTransferPair(String ref,
BufferAllocator allocator) |
TransferPair |
TimeStampMilliTZVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TimeMicroVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
Float8Vector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TimeNanoVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
DecimalVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
BitVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
TimeStampMicroVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
VarBinaryVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising of this and a target vector of
the same type.
|
TransferPair |
DurationVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising of this and a target vector of
the same type.
|
TransferPair |
TimeStampSecTZVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising of this and a target vector of
the same type.
|
TransferPair |
ExtensionTypeVector.getTransferPair(String ref,
BufferAllocator allocator) |
TransferPair |
TimeStampSecVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
Float2Vector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
ValueVector.getTransferPair(String ref,
BufferAllocator allocator)
To transfer quota responsibility.
|
TransferPair |
UInt4Vector.getTransferPair(String ref,
BufferAllocator allocator) |
TransferPair |
TimeMilliVector.getTransferPair(String ref,
BufferAllocator allocator)
Construct a TransferPair comprising this and a target vector of
the same type.
|
TransferPair |
BaseLargeVariableWidthVector.getTransferPair(String ref,
BufferAllocator allocator,
CallBack callBack)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
BaseFixedWidthVector.getTransferPair(String ref,
BufferAllocator allocator,
CallBack callBack)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
ZeroVector.getTransferPair(String ref,
BufferAllocator allocator,
CallBack callBack) |
TransferPair |
NullVector.getTransferPair(String ref,
BufferAllocator allocator,
CallBack callBack) |
TransferPair |
BaseVariableWidthVector.getTransferPair(String ref,
BufferAllocator allocator,
CallBack callBack)
Construct a transfer pair of this vector and another vector of same type.
|
TransferPair |
ExtensionTypeVector.getTransferPair(String ref,
BufferAllocator allocator,
CallBack callBack) |
TransferPair |
ValueVector.getTransferPair(String ref,
BufferAllocator allocator,
CallBack callBack)
To transfer quota responsibility.
|
static ArrowBuf |
BitVectorHelper.loadValidityBuffer(ArrowFieldNode fieldNode,
ArrowBuf sourceValidityBuffer,
BufferAllocator allocator)
Returns a new buffer if the source validity buffer is either all null or all
not-null, otherwise returns a buffer pointing to the same memory as source.
|
static ArrowBuf |
BaseVariableWidthVector.set(ArrowBuf buffer,
BufferAllocator allocator,
int valueCount,
int index,
int value)
Method used by Json Reader to explicitly set the offsets of the variable
width vector data.
|
static ArrowBuf |
BaseLargeVariableWidthVector.set(ArrowBuf buffer,
BufferAllocator allocator,
int valueCount,
int index,
long value)
Method used by Json Reader to explicitly set the offsets of the variable
width vector data.
|
static ArrowBuf |
BitVectorHelper.setValidityBit(ArrowBuf validityBuffer,
BufferAllocator allocator,
int valueCount,
int index,
int value)
Set the bit at a given index to provided value (1 or 0).
|
static ArrowBuf |
BaseValueVector.transferBuffer(ArrowBuf srcBuffer,
BufferAllocator targetAllocator) |
Constructor and Description |
---|
BaseFixedWidthVector(Field field,
BufferAllocator allocator,
int typeWidth)
Constructs a new instance.
|
BaseLargeVariableWidthVector(Field field,
BufferAllocator allocator)
Constructs a new instance.
|
BaseValueVector(BufferAllocator allocator) |
BaseVariableWidthVector(Field field,
BufferAllocator allocator)
Constructs a new instance.
|
BigIntVector(Field field,
BufferAllocator allocator)
Instantiate a BigIntVector.
|
BigIntVector(String name,
BufferAllocator allocator)
Instantiate a BigIntVector.
|
BigIntVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a BigIntVector.
|
BitVector(Field field,
BufferAllocator allocator)
Instantiate a BitVector.
|
BitVector(String name,
BufferAllocator allocator)
Instantiate a BitVector.
|
BitVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a BitVector.
|
DateDayVector(Field field,
BufferAllocator allocator)
Instantiate a DateDayVector.
|
DateDayVector(String name,
BufferAllocator allocator)
Instantiate a DateDayVector.
|
DateDayVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a DateDayVector.
|
DateMilliVector(Field field,
BufferAllocator allocator)
Instantiate a DateMilliVector.
|
DateMilliVector(String name,
BufferAllocator allocator)
Instantiate a DateMilliVector.
|
DateMilliVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a DateMilliVector.
|
Decimal256Vector(Field field,
BufferAllocator allocator)
Instantiate a Decimal256Vector.
|
Decimal256Vector(String name,
BufferAllocator allocator,
int precision,
int scale)
Instantiate a Decimal256Vector.
|
Decimal256Vector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a Decimal256Vector.
|
DecimalVector(Field field,
BufferAllocator allocator)
Instantiate a DecimalVector.
|
DecimalVector(String name,
BufferAllocator allocator,
int precision,
int scale)
Instantiate a DecimalVector.
|
DecimalVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a DecimalVector.
|
DurationVector(Field field,
BufferAllocator allocator)
Instantiate a DurationVector.
|
DurationVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a DurationVector.
|
ExtensionTypeVector(Field field,
BufferAllocator allocator,
T underlyingVector)
Instantiate an extension type vector.
|
ExtensionTypeVector(String name,
BufferAllocator allocator,
T underlyingVector)
Instantiate an extension type vector.
|
FixedSizeBinaryVector(Field field,
BufferAllocator allocator)
Instantiate a FixedSizeBinaryVector.
|
FixedSizeBinaryVector(String name,
BufferAllocator allocator,
int byteWidth)
Instantiate a FixedSizeBinaryVector.
|
FixedSizeBinaryVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a FixedSizeBinaryVector.
|
Float2Vector(Field field,
BufferAllocator allocator)
Instantiate a Float2Vector.
|
Float2Vector(String name,
BufferAllocator allocator)
Instantiate a Float2Vector.
|
Float2Vector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a Float2Vector.
|
Float4Vector(Field field,
BufferAllocator allocator)
Instantiate a Float4Vector.
|
Float4Vector(String name,
BufferAllocator allocator)
Instantiate a Float4Vector.
|
Float4Vector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a Float4Vector.
|
Float8Vector(Field field,
BufferAllocator allocator)
Instantiate a Float8Vector.
|
Float8Vector(String name,
BufferAllocator allocator)
Instantiate a Float8Vector.
|
Float8Vector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a Float8Vector.
|
IntervalDayVector(Field field,
BufferAllocator allocator)
Instantiate a IntervalDayVector.
|
IntervalDayVector(String name,
BufferAllocator allocator)
Instantiate a IntervalDayVector.
|
IntervalDayVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a IntervalDayVector.
|
IntervalMonthDayNanoVector(Field field,
BufferAllocator allocator)
Instantiate a IntervalMonthDayNanoVector.
|
IntervalMonthDayNanoVector(String name,
BufferAllocator allocator)
Instantiate a IntervalMonthDayNanoVector.
|
IntervalMonthDayNanoVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a IntervalMonthDayNanoVector.
|
IntervalYearVector(Field field,
BufferAllocator allocator)
Instantiate a IntervalYearVector.
|
IntervalYearVector(String name,
BufferAllocator allocator)
Instantiate a IntervalYearVector.
|
IntervalYearVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a IntervalYearVector.
|
IntVector(Field field,
BufferAllocator allocator)
Instantiate a IntVector.
|
IntVector(String name,
BufferAllocator allocator)
Instantiate a IntVector.
|
IntVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a IntVector.
|
LargeVarBinaryVector(Field field,
BufferAllocator allocator)
Instantiate a LargeVarBinaryVector.
|
LargeVarBinaryVector(String name,
BufferAllocator allocator)
Instantiate a LargeVarBinaryVector.
|
LargeVarBinaryVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a LargeVarBinaryVector.
|
LargeVarCharVector(Field field,
BufferAllocator allocator)
Instantiate a LargeVarCharVector.
|
LargeVarCharVector(String name,
BufferAllocator allocator)
Instantiate a LargeVarCharVector.
|
LargeVarCharVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a LargeVarCharVector.
|
SmallIntVector(Field field,
BufferAllocator allocator)
Instantiate a SmallIntVector.
|
SmallIntVector(String name,
BufferAllocator allocator)
Instantiate a SmallIntVector.
|
SmallIntVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a SmallIntVector.
|
TimeMicroVector(Field field,
BufferAllocator allocator)
Instantiate a TimeMicroVector.
|
TimeMicroVector(String name,
BufferAllocator allocator)
Instantiate a TimeMicroVector.
|
TimeMicroVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a TimeMicroVector.
|
TimeMilliVector(Field field,
BufferAllocator allocator)
Instantiate a TimeMilliVector.
|
TimeMilliVector(String name,
BufferAllocator allocator)
Instantiate a TimeMilliVector.
|
TimeMilliVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a TimeMilliVector.
|
TimeNanoVector(Field field,
BufferAllocator allocator)
Instantiate a TimeNanoVector.
|
TimeNanoVector(String name,
BufferAllocator allocator)
Instantiate a TimeNanoVector.
|
TimeNanoVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a TimeNanoVector.
|
TimeSecVector(Field field,
BufferAllocator allocator)
Instantiate a TimeSecVector.
|
TimeSecVector(String name,
BufferAllocator allocator)
Instantiate a TimeSecVector.
|
TimeSecVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a TimeSecVector.
|
TimeStampMicroTZVector(Field field,
BufferAllocator allocator)
Instantiate a TimeStampMicroTZVector.
|
TimeStampMicroTZVector(String name,
BufferAllocator allocator,
String timeZone)
Instantiate a TimeStampMicroTZVector.
|
TimeStampMicroTZVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a TimeStampMicroTZVector.
|
TimeStampMicroVector(Field field,
BufferAllocator allocator)
Instantiate a TimeStampMicroVector.
|
TimeStampMicroVector(String name,
BufferAllocator allocator)
Instantiate a TimeStampMicroVector.
|
TimeStampMicroVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a TimeStampMicroVector.
|
TimeStampMilliTZVector(Field field,
BufferAllocator allocator)
Instantiate a TimeStampMilliTZVector.
|
TimeStampMilliTZVector(String name,
BufferAllocator allocator,
String timeZone)
Instantiate a TimeStampMilliTZVector.
|
TimeStampMilliTZVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a TimeStampMilliTZVector.
|
TimeStampMilliVector(Field field,
BufferAllocator allocator)
Instantiate a TimeStampMilliVector.
|
TimeStampMilliVector(String name,
BufferAllocator allocator)
Instantiate a TimeStampMilliVector.
|
TimeStampMilliVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a TimeStampMilliVector.
|
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.
|
TimeStampNanoVector(Field field,
BufferAllocator allocator)
Instantiate a TimeStampNanoVector.
|
TimeStampNanoVector(String name,
BufferAllocator allocator)
Instantiate a TimeStampNanoVector.
|
TimeStampNanoVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a TimeStampNanoVector.
|
TimeStampSecTZVector(Field field,
BufferAllocator allocator)
Instantiate a TimeStampSecTZVector.
|
TimeStampSecTZVector(String name,
BufferAllocator allocator,
String timeZone)
Instantiate a TimeStampSecTZVector.
|
TimeStampSecTZVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a TimeStampSecTZVector.
|
TimeStampSecVector(Field field,
BufferAllocator allocator)
Instantiate a TimeStampSecVector.
|
TimeStampSecVector(String name,
BufferAllocator allocator)
Instantiate a TimeStampSecVector.
|
TimeStampSecVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a TimeStampSecVector.
|
TimeStampVector(Field field,
BufferAllocator allocator)
Instantiate a TimeStampVector.
|
TimeStampVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a TimeStampVector.
|
TinyIntVector(Field field,
BufferAllocator allocator)
Instantiate a TinyIntVector.
|
TinyIntVector(String name,
BufferAllocator allocator)
Instantiate a TinyIntVector.
|
TinyIntVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a TinyIntVector.
|
UInt1Vector(Field field,
BufferAllocator allocator)
Constructor for UInt1Vector.
|
UInt1Vector(String name,
BufferAllocator allocator) |
UInt1Vector(String name,
FieldType fieldType,
BufferAllocator allocator) |
UInt2Vector(Field field,
BufferAllocator allocator)
Constructor for UInt2Vector type.
|
UInt2Vector(String name,
BufferAllocator allocator) |
UInt2Vector(String name,
FieldType fieldType,
BufferAllocator allocator) |
UInt4Vector(Field field,
BufferAllocator allocator)
Constructor for UInt4Vector.
|
UInt4Vector(String name,
BufferAllocator allocator) |
UInt4Vector(String name,
FieldType fieldType,
BufferAllocator allocator) |
UInt8Vector(Field field,
BufferAllocator allocator)
Constructor for UInt8Vector.
|
UInt8Vector(String name,
BufferAllocator allocator) |
UInt8Vector(String name,
FieldType fieldType,
BufferAllocator allocator) |
VarBinaryVector(Field field,
BufferAllocator allocator)
Instantiate a VarBinaryVector.
|
VarBinaryVector(String name,
BufferAllocator allocator)
Instantiate a VarBinaryVector.
|
VarBinaryVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a VarBinaryVector.
|
VarCharVector(Field field,
BufferAllocator allocator)
Instantiate a VarCharVector.
|
VarCharVector(String name,
BufferAllocator allocator)
Instantiate a VarCharVector.
|
VarCharVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Instantiate a VarCharVector.
|
Modifier and Type | Field and Description |
---|---|
protected BufferAllocator |
AbstractContainerVector.allocator |
Modifier and Type | Method and Description |
---|---|
BufferAllocator |
AbstractContainerVector.getAllocator() |
BufferAllocator |
DenseUnionVector.getAllocator() |
BufferAllocator |
UnionVector.getAllocator() |
Constructor and Description |
---|
AbstractContainerVector(String name,
BufferAllocator allocator,
CallBack callBack) |
AbstractStructVector(String name,
BufferAllocator allocator,
CallBack callBack,
AbstractStructVector.ConflictPolicy conflictPolicy,
boolean allowConflictPolicyChanges)
Base constructor that sets default conflict policy to APPEND.
|
BaseRepeatedValueVector(String name,
BufferAllocator allocator,
CallBack callBack) |
BaseRepeatedValueVector(String name,
BufferAllocator allocator,
FieldVector vector,
CallBack callBack) |
DenseUnionVector(String name,
BufferAllocator allocator,
FieldType fieldType,
CallBack callBack) |
FixedSizeListVector(Field field,
BufferAllocator allocator,
CallBack unusedSchemaChangeCallback)
Creates a new instance.
|
FixedSizeListVector(String name,
BufferAllocator allocator,
FieldType fieldType,
CallBack unusedSchemaChangeCallback)
Creates a new instance.
|
LargeListVector(Field field,
BufferAllocator allocator,
CallBack callBack)
Creates a new instance.
|
LargeListVector(String name,
BufferAllocator allocator,
FieldType fieldType,
CallBack callBack)
Constructs a new instance.
|
ListVector(Field field,
BufferAllocator allocator,
CallBack callBack)
Constructs a new instance.
|
ListVector(String name,
BufferAllocator allocator,
FieldType fieldType,
CallBack callBack)
Constructs a new instance.
|
MapVector(Field field,
BufferAllocator allocator,
CallBack callBack) |
MapVector(String name,
BufferAllocator allocator,
FieldType fieldType,
CallBack callBack)
Construct a MapVector instance.
|
NonNullableStructVector(Field field,
BufferAllocator allocator,
CallBack callBack)
Constructs a new instance.
|
NonNullableStructVector(Field field,
BufferAllocator allocator,
CallBack callBack,
AbstractStructVector.ConflictPolicy conflictPolicy,
boolean allowConflictPolicyChanges)
Constructs a new instance.
|
NonNullableStructVector(String name,
BufferAllocator allocator,
FieldType fieldType,
CallBack callBack)
Constructs a new instance.
|
NonNullableStructVector(String name,
BufferAllocator allocator,
FieldType fieldType,
CallBack callBack,
AbstractStructVector.ConflictPolicy conflictPolicy,
boolean allowConflictPolicyChanges)
Constructs a new instance.
|
StructVector(Field field,
BufferAllocator allocator,
CallBack callBack)
Constructs a new instance.
|
StructVector(Field field,
BufferAllocator allocator,
CallBack callBack,
AbstractStructVector.ConflictPolicy conflictPolicy,
boolean allowConflictPolicyChanges)
Constructs a new instance.
|
StructVector(String name,
BufferAllocator allocator,
FieldType fieldType,
CallBack callBack)
Constructs a new instance.
|
StructVector(String name,
BufferAllocator allocator,
FieldType fieldType,
CallBack callBack,
AbstractStructVector.ConflictPolicy conflictPolicy,
boolean allowConflictPolicyChanges)
Constructs a new instance.
|
UnionVector(String name,
BufferAllocator allocator,
FieldType fieldType,
CallBack callBack) |
Modifier and Type | Method and Description |
---|---|
ArrowBuf |
NoCompressionCodec.compress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer) |
ArrowBuf |
CompressionCodec.compress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer)
Compress a buffer.
|
ArrowBuf |
AbstractCompressionCodec.compress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer) |
ArrowBuf |
NoCompressionCodec.decompress(BufferAllocator allocator,
ArrowBuf compressedBuffer) |
ArrowBuf |
CompressionCodec.decompress(BufferAllocator allocator,
ArrowBuf compressedBuffer)
Decompress a buffer.
|
ArrowBuf |
AbstractCompressionCodec.decompress(BufferAllocator allocator,
ArrowBuf compressedBuffer) |
protected abstract ArrowBuf |
AbstractCompressionCodec.doCompress(BufferAllocator allocator,
ArrowBuf uncompressedBuffer)
The method that actually performs the data compression.
|
protected abstract ArrowBuf |
AbstractCompressionCodec.doDecompress(BufferAllocator allocator,
ArrowBuf compressedBuffer)
The method that actually performs the data decompression.
|
static ArrowBuf |
CompressionUtil.packageRawBuffer(BufferAllocator allocator,
ArrowBuf inputBuffer)
Process compression by compressing the buffer as is.
|
Modifier and Type | Method and Description |
---|---|
void |
DictionaryProvider.MapDictionaryProvider.copyStructureFrom(DictionaryProvider other,
BufferAllocator allocator)
Initialize the map structure from another provider, but with empty vectors.
|
static StructVector |
StructSubfieldEncoder.decode(StructVector vector,
DictionaryProvider.MapDictionaryProvider provider,
BufferAllocator allocator)
Decodes a dictionary subfields encoded vector using the provided dictionary.
|
static ValueVector |
DictionaryEncoder.decode(ValueVector indices,
Dictionary dictionary,
BufferAllocator allocator)
Decodes a dictionary encoded array using the provided dictionary.
|
static BaseListVector |
ListSubfieldEncoder.decodeListSubField(BaseListVector vector,
Dictionary dictionary,
BufferAllocator allocator)
Decodes a dictionary subfields encoded vector using the provided dictionary.
|
Constructor and Description |
---|
DictionaryEncoder(Dictionary dictionary,
BufferAllocator allocator)
Construct an instance.
|
DictionaryEncoder(Dictionary dictionary,
BufferAllocator allocator,
ArrowBufHasher hasher)
Construct an instance.
|
ListSubfieldEncoder(Dictionary dictionary,
BufferAllocator allocator) |
ListSubfieldEncoder(Dictionary dictionary,
BufferAllocator allocator,
ArrowBufHasher hasher)
Construct an instance.
|
StructSubfieldEncoder(BufferAllocator allocator,
DictionaryProvider.MapDictionaryProvider provider)
Construct an instance.
|
StructSubfieldEncoder(BufferAllocator allocator,
DictionaryProvider.MapDictionaryProvider provider,
ArrowBufHasher hasher)
Construct an instance.
|
Modifier and Type | Field and Description |
---|---|
protected BufferAllocator |
ArrowReader.allocator |
Constructor and Description |
---|
ArrowFileReader(SeekableByteChannel in,
BufferAllocator allocator) |
ArrowFileReader(SeekableByteChannel in,
BufferAllocator allocator,
CompressionCodec.Factory compressionFactory) |
ArrowFileReader(SeekableReadChannel in,
BufferAllocator allocator) |
ArrowFileReader(SeekableReadChannel in,
BufferAllocator allocator,
CompressionCodec.Factory compressionFactory) |
ArrowReader(BufferAllocator allocator) |
ArrowReader(BufferAllocator allocator,
CompressionCodec.Factory compressionFactory) |
ArrowStreamReader(InputStream in,
BufferAllocator allocator)
Constructs a streaming reader from an InputStream.
|
ArrowStreamReader(InputStream in,
BufferAllocator allocator,
CompressionCodec.Factory compressionFactory)
Constructs a streaming reader from a ReadableByteChannel input.
|
ArrowStreamReader(MessageChannelReader messageReader,
BufferAllocator allocator)
Constructs a streaming reader using a MessageChannelReader.
|
ArrowStreamReader(MessageChannelReader messageReader,
BufferAllocator allocator,
CompressionCodec.Factory compressionFactory)
Constructs a streaming reader using a MessageChannelReader.
|
ArrowStreamReader(ReadableByteChannel in,
BufferAllocator allocator)
Constructs a streaming reader from a ReadableByteChannel input.
|
ArrowStreamReader(ReadableByteChannel in,
BufferAllocator allocator,
CompressionCodec.Factory compressionFactory)
Constructs a streaming reader from a ReadableByteChannel input.
|
JsonFileReader(File inputFile,
BufferAllocator allocator)
Constructs a new instance.
|
Modifier and Type | Field and Description |
---|---|
protected BufferAllocator |
MessageChannelReader.allocator |
Modifier and Type | Method and Description |
---|---|
ArrowRecordBatch |
ArrowRecordBatch.cloneWithTransfer(BufferAllocator allocator)
Create a new ArrowRecordBatch which has the same information as this batch but whose buffers
are owned by that Allocator.
|
static ArrowDictionaryBatch |
MessageSerializer.deserializeDictionaryBatch(ReadChannel in,
ArrowBlock block,
BufferAllocator alloc)
Deserializes a DictionaryBatch knowing the size of the entire message up front.
|
static ArrowDictionaryBatch |
MessageSerializer.deserializeDictionaryBatch(ReadChannel in,
BufferAllocator allocator)
Deserializes an ArrowDictionaryBatch read from the input channel.
|
static ArrowMessage |
MessageSerializer.deserializeMessageBatch(ReadChannel in,
BufferAllocator alloc)
Deserialize a message that is either an ArrowDictionaryBatch or ArrowRecordBatch.
|
static ArrowRecordBatch |
MessageSerializer.deserializeRecordBatch(ReadChannel in,
ArrowBlock block,
BufferAllocator alloc)
Deserializes an ArrowRecordBatch knowing the size of the entire message up front.
|
static ArrowRecordBatch |
MessageSerializer.deserializeRecordBatch(ReadChannel in,
BufferAllocator allocator)
Deserializes an ArrowRecordBatch read from the input channel.
|
static ArrowBuf |
MessageSerializer.readMessageBody(ReadChannel in,
long bodyLength,
BufferAllocator allocator)
Read a Message body from the in channel into an ArrowBuf.
|
Constructor and Description |
---|
MessageChannelReader(ReadChannel in,
BufferAllocator allocator)
Construct a MessageReader to read streaming messages from an existing ReadChannel.
|
Modifier and Type | Method and Description |
---|---|
abstract FieldVector |
Types.MinorType.getNewVector(Field field,
BufferAllocator allocator,
CallBack schemaChangeCallback)
Constructs a new vector for the given type.
|
FieldVector |
Types.MinorType.getNewVector(String name,
FieldType fieldType,
BufferAllocator allocator,
CallBack schemaChangeCallback)
Constructs a new vector for the given type.
|
Modifier and Type | Method and Description |
---|---|
FieldVector |
FieldType.createNewSingleVector(Field field,
BufferAllocator allocator,
CallBack schemaCallBack) |
FieldVector |
FieldType.createNewSingleVector(String name,
BufferAllocator allocator,
CallBack schemaCallBack) |
FieldVector |
Field.createVector(BufferAllocator allocator)
Construct a new vector of this type using the given allocator.
|
abstract FieldVector |
ArrowType.ExtensionType.getNewVector(String name,
FieldType fieldType,
BufferAllocator allocator)
Construct a vector for the user type.
|
Modifier and Type | Method and Description |
---|---|
static Schema |
SchemaUtility.deserialize(byte[] bytes,
BufferAllocator allocator)
Deserialize Arrow schema from byte array.
|
static Field |
DictionaryUtility.toMemoryFormat(Field field,
BufferAllocator allocator,
Map<Long,Dictionary> dictionaries)
Convert field and child fields that have a dictionary encoding to memory format, so fields
have the index type.
|
Copyright © 2024 The Apache Software Foundation. All rights reserved.