Uses of Class
io.netty.buffer.DrillBuf
Package
Description
Drill expression materialization and evaluation facilities.
Memory Allocation, Account and Management
See the README.md file in this directory for detailed information about Drill's memory allocation subsystem.
Version 3 of the text reader.
Package containing writers used to write data from Hive table columns into Drill's value vectors.
Provides a light-weight, simplified set of column readers and writers that
can be plugged into a variety of row-level readers and writers.
Provides the reader hierarchy as explained in the API package.
Implementation of the vector writers.
-
Uses of DrillBuf in io.netty.buffer
Modifier and TypeFieldDescriptionfinal DrillBuf
DrillBuf.TransferResult.buffer
The newly created buffer associated with the target allocator.Modifier and TypeMethodDescriptionDrillBuf.capacity
(int newCapacity) DrillBuf.duplicate()
DrillBuf.reallocIfNeeded
(int size) DrillBuf.retain
(BufferAllocator target) Create a new DrillBuf that is associated with an alternative allocator for the purposes of memory ownership and accounting.DrillBuf.slice
(int index, int length) -
Uses of DrillBuf in org.apache.drill.exec.expr
Modifier and TypeMethodDescriptionMap<org.apache.calcite.util.Pair<Integer,
com.sun.codemodel.JVar>, org.apache.drill.shaded.guava.com.google.common.base.Function<DrillBuf, ? extends ValueHolder>> ClassGenerator.getConstantVars()
Modifier and TypeMethodDescriptionorg.apache.calcite.util.Pair<Integer,
com.sun.codemodel.JVar> ClassGenerator.declareClassConstField
(String prefix, com.sun.codemodel.JType t, com.sun.codemodel.JExpression init, org.apache.drill.shaded.guava.com.google.common.base.Function<DrillBuf, ? extends ValueHolder> function) Declare a constant field for the class.org.apache.calcite.util.Pair<Integer,
com.sun.codemodel.JVar> ClassGenerator.declareClassConstField
(String prefix, com.sun.codemodel.JType t, org.apache.drill.shaded.guava.com.google.common.base.Function<DrillBuf, ? extends ValueHolder> function) -
Uses of DrillBuf in org.apache.drill.exec.expr.fn.impl
Modifier and TypeMethodDescriptionstatic DrillBuf
MappifyUtility.mappify
(FieldReader reader, BaseWriter.ComplexWriter writer, DrillBuf buffer, String caller) Modifier and TypeMethodDescriptionstatic final int
ByteFunctionHelpers.compare
(DrillBuf left, int lStart, int lEnd, byte[] right, int rStart, int rEnd) Helper function to compare a set of bytes in DrillBuf to a ByteArray.static final int
ByteFunctionHelpers.compare
(DrillBuf left, int lStart, int lEnd, DrillBuf right, int rStart, int rEnd) Helper function to compare a set of bytes in two DrillBuffers.static final int
ByteFunctionHelpers.equal
(DrillBuf left, int lStart, int lEnd, DrillBuf right, int rStart, int rEnd) Helper function to check for equality of bytes in two DrillBuffersstatic long
static int
static int
static int
static long
static long
static long
static boolean
StringFunctionHelpers.isReadableAsDate
(DrillBuf buf, int start, int end) Takes a string value, specified as a buffer with a start and end and returns true if the value can be read as a date.static DrillBuf
MappifyUtility.mappify
(FieldReader reader, BaseWriter.ComplexWriter writer, DrillBuf buffer, String caller) int
int
int
int
int
int
static int
MurmurHash3.murmur3_32
(int bStart, int bEnd, DrillBuf buffer, int seed) static long
MurmurHash3.murmur3_64
(long bStart, long bEnd, DrillBuf buffer, int seed) void
Set the DrillBuf to adapt to a CharSequence.static String
StringFunctionHelpers.toStringFromUTF16
(int start, int end, DrillBuf buffer) static String
StringFunctionHelpers.toStringFromUTF8
(int start, int end, DrillBuf buffer) static int
StringFunctionHelpers.varTypesToInt
(int start, int end, DrillBuf buffer) static long
StringFunctionHelpers.varTypesToLong
(int start, int end, DrillBuf buffer) -
Uses of DrillBuf in org.apache.drill.exec.expr.holders
Modifier and TypeFieldDescriptionDecimal28DenseHolder.buffer
Deprecated.Decimal28SparseHolder.buffer
Deprecated.Decimal38DenseHolder.buffer
Deprecated.Decimal38SparseHolder.buffer
Deprecated.NullableDecimal28DenseHolder.buffer
Deprecated.NullableDecimal28SparseHolder.buffer
Deprecated.NullableDecimal38DenseHolder.buffer
Deprecated.NullableDecimal38SparseHolder.buffer
Deprecated.NullableVar16CharHolder.buffer
NullableVarBinaryHolder.buffer
NullableVarCharHolder.buffer
NullableVarDecimalHolder.buffer
Var16CharHolder.buffer
VarBinaryHolder.buffer
VarCharHolder.buffer
VarDecimalHolder.buffer
Modifier and TypeMethodDescriptionstatic int
Decimal28DenseHolder.getInteger
(int index, int start, DrillBuf buffer) Deprecated.static int
Decimal28SparseHolder.getInteger
(int index, int start, DrillBuf buffer) Deprecated.static int
Decimal38DenseHolder.getInteger
(int index, int start, DrillBuf buffer) Deprecated.static int
Decimal38SparseHolder.getInteger
(int index, int start, DrillBuf buffer) Deprecated.static int
NullableDecimal28DenseHolder.getInteger
(int index, int start, DrillBuf buffer) Deprecated.static int
NullableDecimal28SparseHolder.getInteger
(int index, int start, DrillBuf buffer) Deprecated.static int
NullableDecimal38DenseHolder.getInteger
(int index, int start, DrillBuf buffer) Deprecated.static int
NullableDecimal38SparseHolder.getInteger
(int index, int start, DrillBuf buffer) Deprecated.static boolean
Deprecated.static boolean
Deprecated.static boolean
Deprecated.static boolean
Deprecated.static boolean
Deprecated.static boolean
Deprecated.static boolean
Deprecated.static boolean
Deprecated.static void
Decimal28DenseHolder.setInteger
(int index, int value, int start, DrillBuf buffer) Deprecated.static void
Decimal28SparseHolder.setInteger
(int index, int value, int start, DrillBuf buffer) Deprecated.static void
Decimal38DenseHolder.setInteger
(int index, int value, int start, DrillBuf buffer) Deprecated.static void
Decimal38SparseHolder.setInteger
(int index, int value, int start, DrillBuf buffer) Deprecated.static void
NullableDecimal28DenseHolder.setInteger
(int index, int value, int start, DrillBuf buffer) Deprecated.static void
NullableDecimal28SparseHolder.setInteger
(int index, int value, int start, DrillBuf buffer) Deprecated.static void
NullableDecimal38DenseHolder.setInteger
(int index, int value, int start, DrillBuf buffer) Deprecated.static void
NullableDecimal38SparseHolder.setInteger
(int index, int value, int start, DrillBuf buffer) Deprecated.static void
Deprecated.static void
Deprecated.static void
Deprecated.static void
Deprecated.static void
Deprecated.static void
Deprecated.static void
Deprecated.static void
Deprecated. -
Uses of DrillBuf in org.apache.drill.exec.memory
Modifier and TypeMethodDescriptionAllocationReservation.allocateBuffer()
Allocate a buffer whose size is the total of all the add()s made.BaseAllocator.Reservation.allocateBuffer()
BaseAllocator.buffer
(int initialRequestSize) BaseAllocator.buffer
(int initialRequestSize, BufferManager manager) BufferAllocator.buffer
(int size) Allocate a new or reused buffer of the provided size.BufferAllocator.buffer
(int size, BufferManager manager) Allocate a new or reused buffer of the provided size.BaseAllocator.getEmpty()
BufferAllocator.getEmpty()
Get a reference to the empty buffer associated with this allocator.AllocationManager.BufferLedger.newDrillBuf
(int offset, int length) Create a new DrillBuf associated with this AllocationManager and memory.AllocationManager.BufferLedger.newDrillBuf
(int offset, int length, BufferManager manager) Create a new DrillBuf associated with this AllocationManager and memory.BaseAllocator.read
(int length, InputStream in) BufferAllocator.read
(int length, InputStream in) Reads the specified number of bytes into a new Drillbuf.Modifier and TypeMethodDescriptionstatic void
BoundsChecking.ensureWritable
(DrillBuf buf, int minWritableBytes) static void
BoundsChecking.lengthCheck
(DrillBuf buf, int start, int length) static void
BoundsChecking.rangeCheck
(DrillBuf buf, int start, int end) static void
BoundsChecking.rangeCheck
(DrillBuf buf1, int start1, int end1, DrillBuf buf2, int start2, int end2) void
BaseAllocator.read
(DrillBuf buf, int length, InputStream in) void
BufferAllocator.read
(DrillBuf buf, int length, InputStream in) Read the contents of a DrillBuf from a stream.void
BaseAllocator.write
(DrillBuf buf, int length, OutputStream out) void
BaseAllocator.write
(DrillBuf buf, OutputStream out) void
BufferAllocator.write
(DrillBuf buf, int length, OutputStream out) Write the contents of a DrillBuf to a stream.void
BufferAllocator.write
(DrillBuf buf, OutputStream out) Write the contents of a DrillBuf to a stream. -
Uses of DrillBuf in org.apache.drill.exec.ops
Modifier and TypeMethodDescriptionBaseFragmentContext.getManagedBuffer()
BaseFragmentContext.getManagedBuffer
(int size) BaseOperatorContext.getManagedBuffer()
BaseOperatorContext.getManagedBuffer
(int size) BufferManager.getManagedBuffer()
Get a managed buffer of indeterminate size.BufferManager.getManagedBuffer
(int size) Get a managed buffer of at least a certain size.BufferManagerImpl.getManagedBuffer()
BufferManagerImpl.getManagedBuffer
(int size) FragmentContext.getManagedBuffer()
FragmentContext.getManagedBuffer
(int size) FragmentContextInterface.getManagedBuffer()
FragmentContextInterface.getManagedBuffer
(int size) OperatorContext.getManagedBuffer()
OperatorContext.getManagedBuffer
(int size) QueryContext.getManagedBuffer()
UdfUtilities.getManagedBuffer()
For UDFs to allocate general purpose intermediate buffers we provide the DrillBuf type as an injectable, which provides access to an off-heap buffer that can be tracked by Drill and re-allocated as needed.Replace an old buffer with a new version at least of the provided size.Modifier and TypeMethodDescriptionReplace an old buffer with a new version at least of the provided size.Modifier and TypeMethodDescriptionFragmentContextImpl.getConstantValueHolder
(String value, TypeProtos.MinorType type, org.apache.drill.shaded.guava.com.google.common.base.Function<DrillBuf, ValueHolder> holderInitializer) QueryContext.getConstantValueHolder
(String value, TypeProtos.MinorType type, org.apache.drill.shaded.guava.com.google.common.base.Function<DrillBuf, ValueHolder> holderInitializer) UdfUtilities.getConstantValueHolder
(String value, TypeProtos.MinorType type, org.apache.drill.shaded.guava.com.google.common.base.Function<DrillBuf, ValueHolder> holderInitializer) Works with value holders cache which holds constant value and its wrapper by type. -
Uses of DrillBuf in org.apache.drill.exec.physical.impl
Modifier and TypeMethodDescriptionOutputMutator.getManagedBuffer()
Allows a scanner to request a set of managed block of memory.ScanBatch.Mutator.getManagedBuffer()
-
Uses of DrillBuf in org.apache.drill.exec.planner.sql
ModifierConstructorDescriptionHivePartitionDescriptor
(PlannerSettings settings, DrillScanRel scanRel, DrillBuf managedBuffer, String defaultPartitionValue) -
Uses of DrillBuf in org.apache.drill.exec.record
Modifier and TypeMethodDescriptionRawFragmentBatch.getBody()
DrillBuf[]
WritableBatch.getBuffers()
Modifier and TypeMethodDescriptionboolean
RecordBatchLoader.load
(UserBitShared.RecordBatchDef def, DrillBuf buf) Load a record batch from a single buffer.ModifierConstructorDescriptionRawFragmentBatch
(BitData.FragmentRecordBatch header, DrillBuf body, AckSender sender) -
Uses of DrillBuf in org.apache.drill.exec.record.selection
Modifier and TypeMethodDescriptionSelectionVector2.getBuffer()
SelectionVector2.getBuffer
(boolean clear) ModifierConstructorDescriptionSelectionVector2
(BufferAllocator allocator, DrillBuf buf, int count) Create a selection vector with the given buffer.SelectionVector2
(BufferAllocator allocator, DrillBuf buf, int count, int actualRecordCount) -
Uses of DrillBuf in org.apache.drill.exec.rpc.control
Modifier and TypeMethodDescriptionCustomHandlerRegistry.handle
(BitControl.CustomMessage message, DrillBuf dBody) Handle an incoming message. -
Uses of DrillBuf in org.apache.drill.exec.rpc.data
ModifierConstructorDescriptionIncomingDataBatch
(BitData.FragmentRecordBatch header, DrillBuf body, AckSender sender) Create a new batch. -
Uses of DrillBuf in org.apache.drill.exec.rpc.user
-
Uses of DrillBuf in org.apache.drill.exec.store.bson
ModifierConstructorDescriptionBsonRecordReader
(DrillBuf managedBuf, boolean allTextMode, boolean readNumbersAsDouble) BsonRecordReader
(DrillBuf managedBuf, List<SchemaPath> columns, boolean readNumbersAsDouble) -
Uses of DrillBuf in org.apache.drill.exec.store.easy.json.loader
Modifier and TypeMethodDescriptionJsonLoaderImpl.JsonLoaderBuilder.fromStream
(int start, int end, DrillBuf buf) -
Uses of DrillBuf in org.apache.drill.exec.store.easy.json.reader
ModifierConstructorDescriptionBaseJsonProcessor
(DrillBuf workBuf, boolean enableNanInf, boolean enableEscapeAnyChar) BaseJsonReader
(DrillBuf workBuf, boolean enableNanInf, boolean enableEscapeAnyChar, boolean skipOuterList) CountingJsonReader
(DrillBuf workBuf, boolean enableNanInf, boolean enableEscapeAnyChar) -
Uses of DrillBuf in org.apache.drill.exec.store.easy.text.reader
ModifierConstructorDescriptionTextReader
(TextParsingSettings settings, org.apache.drill.exec.store.easy.text.reader.TextInput input, org.apache.drill.exec.store.easy.text.reader.TextOutput output, DrillBuf workBuf) The CsvParser supports all settings provided byTextParsingSettings
, and requires this configuration to be properly initialized. -
Uses of DrillBuf in org.apache.drill.exec.store.hive
Modifier and TypeMethodDescriptionstatic void
HiveUtilities.populateVector
(ValueVector vector, DrillBuf managedBuffer, Object val, int start, int end) Populates vector with given value based on its type. -
Uses of DrillBuf in org.apache.drill.exec.store.hive.writers
ModifierConstructorDescriptionHiveValueWriterFactory
(DrillBuf drillBuf, SingleMapWriter rootWriter) -
Uses of DrillBuf in org.apache.drill.exec.store.hive.writers.primitive
ModifierConstructorDescriptionHiveBinaryWriter
(org.apache.hadoop.hive.serde2.objectinspector.primitive.BinaryObjectInspector inspector, VarBinaryWriter writer, DrillBuf drillBuf) HiveCharWriter
(org.apache.hadoop.hive.serde2.objectinspector.primitive.HiveCharObjectInspector inspector, VarCharWriter writer, DrillBuf drillBuf) HiveStringWriter
(org.apache.hadoop.hive.serde2.objectinspector.primitive.StringObjectInspector inspector, VarCharWriter writer, DrillBuf drillBuf) HiveVarCharWriter
(org.apache.hadoop.hive.serde2.objectinspector.primitive.HiveVarcharObjectInspector inspector, VarCharWriter writer, DrillBuf drillBuf) -
Uses of DrillBuf in org.apache.drill.exec.store.parquet
-
Uses of DrillBuf in org.apache.drill.exec.store.parquet.columnreaders
Modifier and TypeFieldDescriptionprotected DrillBuf
NullableFixedByteAlignedReaders.NullableFixedByteAlignedReader.bytebuf
protected DrillBuf
NullableFixedByteAlignedReaders.NullableFixedByteAlignedReader.bytebuf
protected DrillBuf
NullableFixedByteAlignedReaders.NullableFixedByteAlignedReader.bytebuf
protected DrillBuf
NullableFixedByteAlignedReaders.NullableFixedByteAlignedReader.bytebuf
protected DrillBuf
ColumnReader.vectorData
Modifier and TypeMethodDescriptionstatic int
ColumnReader.readIntLittleEndian
(DrillBuf in, int offset) This is copied out of Parquet library, didn't want to deal with the unnecessary throws statement they had declaredabstract boolean
boolean
VarLengthColumnReaders.NullableVarBinaryColumn.setSafe
(int index, DrillBuf value, int start, int length) boolean
VarLengthColumnReaders.NullableVarCharColumn.setSafe
(int index, DrillBuf value, int start, int length) boolean
VarLengthColumnReaders.NullableVarDecimalColumn.setSafe
(int index, DrillBuf value, int start, int length) final boolean
boolean
boolean
abstract boolean
Store a variable length entry if there is enough memory. -
Uses of DrillBuf in org.apache.drill.exec.store.parquet.columnreaders.batchsizing
-
Uses of DrillBuf in org.apache.drill.exec.store.parquet.decimal
Modifier and TypeMethodDescriptionvoid
BinaryDecimalParquetValueWriter.writeValue
(org.apache.parquet.io.api.RecordConsumer consumer, DrillBuf buffer, int start, int end, int precision) abstract void
DecimalValueWriter.writeValue
(org.apache.parquet.io.api.RecordConsumer consumer, DrillBuf buffer, int start, int end, int precision) Takes value from specifiedDrillBuf buffer
, converts it into required format if needed and passes the value into specifiedRecordConsumer consumer
.void
FixedLenDecimalParquetValueWriter.writeValue
(org.apache.parquet.io.api.RecordConsumer consumer, DrillBuf buffer, int start, int end, int precision) void
Int32DecimalParquetValueWriter.writeValue
(org.apache.parquet.io.api.RecordConsumer consumer, DrillBuf buffer, int start, int end, int precision) void
Int64DecimalParquetValueWriter.writeValue
(org.apache.parquet.io.api.RecordConsumer consumer, DrillBuf buffer, int start, int end, int precision) -
Uses of DrillBuf in org.apache.drill.exec.store.parquet2
ModifierConstructorDescriptionDrillFixedBinaryToVarbinaryConverter
(VarBinaryWriter writer, int length, DrillBuf buf) DrillVarBinaryConverter
(VarBinaryWriter writer, DrillBuf buf) DrillVarCharConverter
(VarCharWriter writer, DrillBuf buf) DrillVarDecimalConverter
(VarDecimalWriter writer, int precision, int scale, DrillBuf buf) -
Uses of DrillBuf in org.apache.drill.exec.store.pojo
Modifier and TypeMethodDescriptionstatic PojoWriter
Creates matching writer to the given field type.ModifierConstructorDescriptionEnumWriter
(String fieldName, DrillBuf managedBuf) StringWriter
(String fieldName, DrillBuf managedBuf) -
Uses of DrillBuf in org.apache.drill.exec.udfs
Modifier and TypeMethodDescriptionstatic DrillBuf
ComplexSchemaUtils.getFields
(FieldReader reader, BaseWriter.ComplexWriter outWriter, DrillBuf buffer) Modifier and TypeMethodDescriptionstatic DrillBuf
ComplexSchemaUtils.getFields
(FieldReader reader, BaseWriter.ComplexWriter outWriter, DrillBuf buffer) -
Uses of DrillBuf in org.apache.drill.exec.util
Modifier and TypeMethodDescriptionstatic void
ByteBufUtil.checkBufferLength
(DrillBuf buffer, int start, int end, int requiredLen) Verifies that the the space provided in the buffer is of specified size.static int
DecimalUtility.compareVarLenBytes
(DrillBuf left, int leftStart, int leftEnd, int leftScale, byte[] right, int rightScale, boolean absCompare) Compares two VarDecimal values, still stored in Drill buffer and byte arraystatic int
DecimalUtility.compareVarLenBytes
(DrillBuf left, int leftStart, int leftEnd, int leftScale, DrillBuf right, int rightStart, int rightEnd, int rightScale, boolean absCompare) Compares two VarDecimal values, still stored in their respective Drill buffersstatic BigDecimal
DecimalUtility.getBigDecimalFromDense
(DrillBuf data, int startIndex, int nDecimalDigits, int scale, int maxPrecision, int width) Returns a BigDecimal object from the dense decimal representation.static BigDecimal
DecimalUtility.getBigDecimalFromDrillBuf
(DrillBuf bytebuf, int start, int length, int scale) Create a BigDecimal object using the data in the DrillBuf.static BigDecimal
DecimalUtility.getBigDecimalFromSparse
(DrillBuf data, int startIndex, int nDecimalDigits, int scale) Create a BigDecimal object using the data in the DrillBuf.static int
Reads a zero-compressed encoded integer from input stream and returns it.static long
Reads a zero-compressed encoded long from input stream and returns it.static void
Serializes an integer to a binary stream with zero-compressed encoding.static void
ByteBufUtil.HadoopWritables.writeVLong
(DrillBuf buffer, int start, int end, long i) Serializes a long to a binary stream with zero-compressed encoding. -
Uses of DrillBuf in org.apache.drill.exec.util.filereader
Modifier and TypeFieldDescriptionprotected DrillBuf
BufferedDirectBufInputStream.internalBuffer
The internal buffer to keep data read from the underlying inputStream.Modifier and TypeMethodDescriptionint
Has the same contract asInputStream.read(byte[], int, int)
Except with DrillBufint
-
Uses of DrillBuf in org.apache.drill.exec.vector
Modifier and TypeMethodDescriptionDecimal28DenseVector.Accessor.get
(int index) Decimal28SparseVector.Accessor.get
(int index) Decimal38DenseVector.Accessor.get
(int index) Decimal38SparseVector.Accessor.get
(int index) IntervalDayVector.Accessor.get
(int index) IntervalVector.Accessor.get
(int index) NullableDecimal28DenseVector.Accessor.get
(int index) Get the element at the specified position.NullableDecimal28SparseVector.Accessor.get
(int index) Get the element at the specified position.NullableDecimal38DenseVector.Accessor.get
(int index) Get the element at the specified position.NullableDecimal38SparseVector.Accessor.get
(int index) Get the element at the specified position.NullableIntervalDayVector.Accessor.get
(int index) Get the element at the specified position.NullableIntervalVector.Accessor.get
(int index) Get the element at the specified position.RepeatedDecimal28DenseVector.Accessor.get
(int index, int positionIndex) Get a value for the given record.RepeatedDecimal28SparseVector.Accessor.get
(int index, int positionIndex) Get a value for the given record.RepeatedDecimal38DenseVector.Accessor.get
(int index, int positionIndex) Get a value for the given record.RepeatedDecimal38SparseVector.Accessor.get
(int index, int positionIndex) Get a value for the given record.RepeatedIntervalDayVector.Accessor.get
(int index, int positionIndex) Get a value for the given record.RepeatedIntervalVector.Accessor.get
(int index, int positionIndex) Get a value for the given record.BaseDataValueVector.getBuffer()
NullableBigIntVector.getBuffer()
NullableBitVector.getBuffer()
NullableDateVector.getBuffer()
NullableDecimal18Vector.getBuffer()
NullableDecimal28DenseVector.getBuffer()
NullableDecimal28SparseVector.getBuffer()
NullableDecimal38DenseVector.getBuffer()
NullableDecimal38SparseVector.getBuffer()
NullableDecimal9Vector.getBuffer()
NullableFloat4Vector.getBuffer()
NullableFloat8Vector.getBuffer()
NullableIntervalDayVector.getBuffer()
NullableIntervalVector.getBuffer()
NullableIntervalYearVector.getBuffer()
NullableIntVector.getBuffer()
NullableSmallIntVector.getBuffer()
NullableTimeStampVector.getBuffer()
NullableTimeVector.getBuffer()
NullableTinyIntVector.getBuffer()
NullableUInt1Vector.getBuffer()
NullableUInt2Vector.getBuffer()
NullableUInt4Vector.getBuffer()
NullableUInt8Vector.getBuffer()
NullableVar16CharVector.getBuffer()
NullableVarBinaryVector.getBuffer()
NullableVarCharVector.getBuffer()
NullableVarDecimalVector.getBuffer()
DrillBuf[]
BaseDataValueVector.getBuffers
(boolean clear) DrillBuf[]
NullableBigIntVector.getBuffers
(boolean clear) DrillBuf[]
NullableBitVector.getBuffers
(boolean clear) DrillBuf[]
NullableDateVector.getBuffers
(boolean clear) DrillBuf[]
NullableDecimal18Vector.getBuffers
(boolean clear) DrillBuf[]
NullableDecimal28DenseVector.getBuffers
(boolean clear) DrillBuf[]
NullableDecimal28SparseVector.getBuffers
(boolean clear) DrillBuf[]
NullableDecimal38DenseVector.getBuffers
(boolean clear) DrillBuf[]
NullableDecimal38SparseVector.getBuffers
(boolean clear) DrillBuf[]
NullableDecimal9Vector.getBuffers
(boolean clear) DrillBuf[]
NullableFloat4Vector.getBuffers
(boolean clear) DrillBuf[]
NullableFloat8Vector.getBuffers
(boolean clear) DrillBuf[]
NullableIntervalDayVector.getBuffers
(boolean clear) DrillBuf[]
NullableIntervalVector.getBuffers
(boolean clear) DrillBuf[]
NullableIntervalYearVector.getBuffers
(boolean clear) DrillBuf[]
NullableIntVector.getBuffers
(boolean clear) DrillBuf[]
NullableSmallIntVector.getBuffers
(boolean clear) DrillBuf[]
NullableTimeStampVector.getBuffers
(boolean clear) DrillBuf[]
NullableTimeVector.getBuffers
(boolean clear) DrillBuf[]
NullableTinyIntVector.getBuffers
(boolean clear) DrillBuf[]
NullableUInt1Vector.getBuffers
(boolean clear) DrillBuf[]
NullableUInt2Vector.getBuffers
(boolean clear) DrillBuf[]
NullableUInt4Vector.getBuffers
(boolean clear) DrillBuf[]
NullableUInt8Vector.getBuffers
(boolean clear) DrillBuf[]
NullableVar16CharVector.getBuffers
(boolean clear) DrillBuf[]
NullableVarBinaryVector.getBuffers
(boolean clear) DrillBuf[]
NullableVarCharVector.getBuffers
(boolean clear) DrillBuf[]
NullableVarDecimalVector.getBuffers
(boolean clear) DrillBuf[]
ObjectVector.getBuffers
(boolean clear) DrillBuf[]
ValueVector.getBuffers
(boolean clear) Return the underlying buffers associated with this vector.DrillBuf[]
Var16CharVector.getBuffers
(boolean clear) DrillBuf[]
VarBinaryVector.getBuffers
(boolean clear) DrillBuf[]
VarCharVector.getBuffers
(boolean clear) DrillBuf[]
VarDecimalVector.getBuffers
(boolean clear) DrillBuf[]
ZeroVector.getBuffers
(boolean clear) VarLenBulkEntry.getData()
abstract DrillBuf
BaseDataValueVector.reallocRaw
(int newAllocationSize) Core of vector allocation.BigIntVector.reallocRaw
(int newAllocationSize) BitVector.reallocRaw
(int newAllocationSize) DateVector.reallocRaw
(int newAllocationSize) Decimal18Vector.reallocRaw
(int newAllocationSize) Decimal28DenseVector.reallocRaw
(int newAllocationSize) Decimal28SparseVector.reallocRaw
(int newAllocationSize) Decimal38DenseVector.reallocRaw
(int newAllocationSize) Decimal38SparseVector.reallocRaw
(int newAllocationSize) Decimal9Vector.reallocRaw
(int newAllocationSize) Float4Vector.reallocRaw
(int newAllocationSize) Float8Vector.reallocRaw
(int newAllocationSize) IntervalDayVector.reallocRaw
(int newAllocationSize) IntervalVector.reallocRaw
(int newAllocationSize) IntervalYearVector.reallocRaw
(int newAllocationSize) IntVector.reallocRaw
(int newAllocationSize) NullableBigIntVector.reallocRaw
(int newAllocationSize) NullableBitVector.reallocRaw
(int newAllocationSize) NullableDateVector.reallocRaw
(int newAllocationSize) NullableDecimal18Vector.reallocRaw
(int newAllocationSize) NullableDecimal28DenseVector.reallocRaw
(int newAllocationSize) NullableDecimal28SparseVector.reallocRaw
(int newAllocationSize) NullableDecimal38DenseVector.reallocRaw
(int newAllocationSize) NullableDecimal38SparseVector.reallocRaw
(int newAllocationSize) NullableDecimal9Vector.reallocRaw
(int newAllocationSize) NullableFloat4Vector.reallocRaw
(int newAllocationSize) NullableFloat8Vector.reallocRaw
(int newAllocationSize) NullableIntervalDayVector.reallocRaw
(int newAllocationSize) NullableIntervalVector.reallocRaw
(int newAllocationSize) NullableIntervalYearVector.reallocRaw
(int newAllocationSize) NullableIntVector.reallocRaw
(int newAllocationSize) NullableSmallIntVector.reallocRaw
(int newAllocationSize) NullableTimeStampVector.reallocRaw
(int newAllocationSize) NullableTimeVector.reallocRaw
(int newAllocationSize) NullableTinyIntVector.reallocRaw
(int newAllocationSize) NullableUInt1Vector.reallocRaw
(int newAllocationSize) NullableUInt2Vector.reallocRaw
(int newAllocationSize) NullableUInt4Vector.reallocRaw
(int newAllocationSize) NullableUInt8Vector.reallocRaw
(int newAllocationSize) NullableVar16CharVector.reallocRaw
(int newAllocationSize) NullableVarBinaryVector.reallocRaw
(int newAllocationSize) NullableVarCharVector.reallocRaw
(int newAllocationSize) NullableVarDecimalVector.reallocRaw
(int newAllocationSize) SmallIntVector.reallocRaw
(int newAllocationSize) TimeStampVector.reallocRaw
(int newAllocationSize) TimeVector.reallocRaw
(int newAllocationSize) TinyIntVector.reallocRaw
(int newAllocationSize) UInt1Vector.reallocRaw
(int newAllocationSize) UInt2Vector.reallocRaw
(int newAllocationSize) UInt4Vector.reallocRaw
(int newAllocationSize) UInt8Vector.reallocRaw
(int newAllocationSize) UntypedNullVector.reallocRaw
(int newAllocationSize) Var16CharVector.reallocRaw
(int newAllocationSize) VarBinaryVector.reallocRaw
(int newAllocationSize) VarCharVector.reallocRaw
(int newAllocationSize) VarDecimalVector.reallocRaw
(int newAllocationSize) Modifier and TypeMethodDescriptionvoid
Add an element to the given record index.void
Add an element to the given record index.void
Add an element to the given record index.void
Add an element to the given record index.void
Add an element to the given record index.void
Add an element to the given record index.void
void
void
void
void
void
void
void
void
void
static Decimal28SparseHolder
ValueHolderHelper.getDecimal28Holder
(DrillBuf buf, String decimal) static Decimal28SparseHolder
ValueHolderHelper.getDecimal28Holder
(DrillBuf buf, BigDecimal bigDecimal) static Decimal38SparseHolder
ValueHolderHelper.getDecimal38Holder
(DrillBuf buf, String decimal) static Decimal38SparseHolder
ValueHolderHelper.getDecimal38Holder
(DrillBuf buf, BigDecimal bigDecimal) static VarCharHolder
ValueHolderHelper.getVarCharHolder
(DrillBuf buf, String s) static VarDecimalHolder
ValueHolderHelper.getVarDecimalHolder
(DrillBuf buf, String decimal) static VarDecimalHolder
ValueHolderHelper.getVarDecimalHolder
(DrillBuf buf, BigDecimal bigDecimal) void
BigIntVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
BitVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
DateVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
Decimal18Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
Decimal28DenseVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
Decimal28SparseVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
Decimal38DenseVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
Decimal38SparseVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
Decimal9Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
Float4Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
Float8Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
IntervalDayVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
IntervalVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
IntervalYearVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
IntVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableBigIntVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableBitVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableDateVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableDecimal18Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableDecimal28DenseVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableDecimal28SparseVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableDecimal38DenseVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableDecimal38SparseVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableDecimal9Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableFloat4Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableFloat8Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableIntervalDayVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableIntervalVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableIntervalYearVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableIntVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableSmallIntVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableTimeStampVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableTimeVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableTinyIntVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableUInt1Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableUInt2Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableUInt4Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableUInt8Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableVar16CharVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableVarBinaryVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableVarCharVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
NullableVarDecimalVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
ObjectVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
SmallIntVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
TimeStampVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
TimeVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
TinyIntVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
UInt1Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
UInt2Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
UInt4Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
UInt8Vector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
UntypedNullVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
ValueVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) Load the data provided in the buffer.void
Var16CharVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
VarBinaryVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
VarCharVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
VarDecimalVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
ZeroVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
void
Set the element at the given index to the given value.void
void
Set the element at the given index to the given value.void
void
Set the element at the given index to the given value.void
void
Set the element at the given index to the given value.void
Set the element at the given index to the given value.void
Set the element at the given index to the given value.void
NullableDecimal28DenseVector.Mutator.set
(int index, int isSet, int startField, DrillBuf bufferField) void
Set the variable length element at the specified index to the supplied value.void
NullableDecimal28SparseVector.Mutator.set
(int index, int isSet, int startField, DrillBuf bufferField) void
Set the variable length element at the specified index to the supplied value.void
NullableDecimal38DenseVector.Mutator.set
(int index, int isSet, int startField, DrillBuf bufferField) void
Set the variable length element at the specified index to the supplied value.void
NullableDecimal38SparseVector.Mutator.set
(int index, int isSet, int startField, DrillBuf bufferField) void
Set the variable length element at the specified index to the supplied value.void
Set the variable length element at the specified index to the supplied value.void
Set the variable length element at the specified index to the supplied value.void
NullableVar16CharVector.Mutator.set
(int index, int isSet, int startField, int endField, DrillBuf bufferField) void
NullableVarBinaryVector.Mutator.set
(int index, int isSet, int startField, int endField, DrillBuf bufferField) void
NullableVarCharVector.Mutator.set
(int index, int isSet, int startField, int endField, DrillBuf bufferField) void
NullableVarDecimalVector.Mutator.set
(int index, int isSet, int startField, int endField, DrillBuf bufferField) protected void
protected void
protected void
protected void
void
void
void
void
void
void
void
void
void
void
void
NullableDecimal28DenseVector.Mutator.setSafe
(int index, int isSet, int startField, DrillBuf bufferField) void
NullableDecimal28SparseVector.Mutator.setSafe
(int index, int isSet, int startField, DrillBuf bufferField) void
NullableDecimal38DenseVector.Mutator.setSafe
(int index, int isSet, int startField, DrillBuf bufferField) void
NullableDecimal38SparseVector.Mutator.setSafe
(int index, int isSet, int startField, DrillBuf bufferField) void
NullableVar16CharVector.Mutator.setSafe
(int index, int isSet, int startField, int endField, DrillBuf bufferField) void
NullableVarBinaryVector.Mutator.setSafe
(int index, int isSet, int startField, int endField, DrillBuf bufferField) void
NullableVarCharVector.Mutator.setSafe
(int index, int isSet, int startField, int endField, DrillBuf bufferField) void
NullableVarDecimalVector.Mutator.setSafe
(int index, int isSet, int startField, int endField, DrillBuf bufferField) void
void
void
void
-
Uses of DrillBuf in org.apache.drill.exec.vector.accessor
Modifier and TypeMethodDescriptionfinal void
ColumnAccessors.Decimal18ColumnWriter.writeDecimal
(DrillBuf buf, BigDecimal value) final void
ColumnAccessors.Decimal28SparseColumnWriter.writeDecimal
(DrillBuf buf, BigDecimal value) final void
ColumnAccessors.Decimal38SparseColumnWriter.writeDecimal
(DrillBuf buf, BigDecimal value) final void
ColumnAccessors.Decimal9ColumnWriter.writeDecimal
(DrillBuf buf, BigDecimal value) final void
ColumnAccessors.Float8ColumnWriter.writeDouble
(DrillBuf buf, double value) final void
ColumnAccessors.Float4ColumnWriter.writeFloat
(DrillBuf buf, float value) final void
final void
final void
final void
final void
final void
final void
final void
final void
final void
final void
final void
ColumnAccessors.IntervalColumnWriter.writePeriod
(DrillBuf buf, org.joda.time.Period value) final void
ColumnAccessors.IntervalDayColumnWriter.writePeriod
(DrillBuf buf, org.joda.time.Period value) final void
ColumnAccessors.IntervalYearColumnWriter.writePeriod
(DrillBuf buf, org.joda.time.Period value) -
Uses of DrillBuf in org.apache.drill.exec.vector.accessor.reader
-
Uses of DrillBuf in org.apache.drill.exec.vector.accessor.writer
-
Uses of DrillBuf in org.apache.drill.exec.vector.complex
Modifier and TypeMethodDescriptionDrillBuf[]
AbstractMapVector.getBuffers
(boolean clear) DrillBuf[]
AbstractRepeatedMapVector.getBuffers
(boolean clear) DrillBuf[]
BaseRepeatedValueVector.getBuffers
(boolean clear) DrillBuf[]
ListVector.getBuffers
(boolean clear) DrillBuf[]
MapVector.getBuffers
(boolean clear) DrillBuf[]
RepeatedListVector.getBuffers
(boolean clear) DrillBuf[]
UnionVector.getBuffers
(boolean clear) Modifier and TypeMethodDescriptionvoid
AbstractRepeatedMapVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
BaseRepeatedValueVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
ListVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) void
MapVector.load
(UserBitShared.SerializedField metadata, DrillBuf buf) void
RepeatedListVector.load
(UserBitShared.SerializedField metadata, DrillBuf buf) void
UnionVector.load
(UserBitShared.SerializedField metadata, DrillBuf buffer) -
Uses of DrillBuf in org.apache.drill.exec.vector.complex.fn
-
Uses of DrillBuf in org.apache.drill.exec.vector.complex.impl
Modifier and TypeMethodDescriptionvoid
Decimal28DenseWriterImpl.writeDecimal28Dense
(int start, DrillBuf buffer, int precision, int scale) void
NullableDecimal28DenseWriterImpl.writeDecimal28Dense
(int start, DrillBuf buffer, int precision, int scale) void
Decimal28SparseWriterImpl.writeDecimal28Sparse
(int start, DrillBuf buffer, int precision, int scale) void
NullableDecimal28SparseWriterImpl.writeDecimal28Sparse
(int start, DrillBuf buffer, int precision, int scale) void
Decimal38DenseWriterImpl.writeDecimal38Dense
(int start, DrillBuf buffer, int precision, int scale) void
NullableDecimal38DenseWriterImpl.writeDecimal38Dense
(int start, DrillBuf buffer, int precision, int scale) void
Decimal38SparseWriterImpl.writeDecimal38Sparse
(int start, DrillBuf buffer, int precision, int scale) void
NullableDecimal38SparseWriterImpl.writeDecimal38Sparse
(int start, DrillBuf buffer, int precision, int scale) void
NullableVar16CharWriterImpl.writeVar16Char
(int start, int end, DrillBuf buffer) void
RepeatedVar16CharWriterImpl.writeVar16Char
(int start, int end, DrillBuf buffer) void
UnionListWriter.writeVar16Char
(int start, int end, DrillBuf buffer) void
UnionWriter.writeVar16Char
(int start, int end, DrillBuf buffer) void
Var16CharWriterImpl.writeVar16Char
(int start, int end, DrillBuf buffer) void
NullableVarBinaryWriterImpl.writeVarBinary
(int start, int end, DrillBuf buffer) void
RepeatedVarBinaryWriterImpl.writeVarBinary
(int start, int end, DrillBuf buffer) void
UnionListWriter.writeVarBinary
(int start, int end, DrillBuf buffer) void
UnionWriter.writeVarBinary
(int start, int end, DrillBuf buffer) void
VarBinaryWriterImpl.writeVarBinary
(int start, int end, DrillBuf buffer) void
NullableVarCharWriterImpl.writeVarChar
(int start, int end, DrillBuf buffer) void
RepeatedVarCharWriterImpl.writeVarChar
(int start, int end, DrillBuf buffer) void
UnionListWriter.writeVarChar
(int start, int end, DrillBuf buffer) void
UnionWriter.writeVarChar
(int start, int end, DrillBuf buffer) void
VarCharWriterImpl.writeVarChar
(int start, int end, DrillBuf buffer) void
NullableVarDecimalWriterImpl.writeVarDecimal
(int start, int end, DrillBuf buffer, int precision, int scale) void
RepeatedVarDecimalWriterImpl.writeVarDecimal
(int start, int end, DrillBuf buffer, int precision, int scale) void
UnionListWriter.writeVarDecimal
(int start, int end, DrillBuf buffer, int precision, int scale) void
UnionWriter.writeVarDecimal
(int start, int end, DrillBuf buffer, int precision, int scale) void
VarDecimalWriterImpl.writeVarDecimal
(int start, int end, DrillBuf buffer, int precision, int scale) -
Uses of DrillBuf in org.apache.drill.exec.vector.complex.writer
Modifier and TypeMethodDescriptionvoid
Decimal28DenseWriter.writeDecimal28Dense
(int start, DrillBuf buffer, int precision, int scale) void
NullableDecimal28DenseWriter.writeDecimal28Dense
(int start, DrillBuf buffer, int precision, int scale) void
RepeatedDecimal28DenseWriter.writeDecimal28Dense
(int start, DrillBuf buffer, int precision, int scale) void
Decimal28SparseWriter.writeDecimal28Sparse
(int start, DrillBuf buffer, int precision, int scale) void
NullableDecimal28SparseWriter.writeDecimal28Sparse
(int start, DrillBuf buffer, int precision, int scale) void
RepeatedDecimal28SparseWriter.writeDecimal28Sparse
(int start, DrillBuf buffer, int precision, int scale) void
Decimal38DenseWriter.writeDecimal38Dense
(int start, DrillBuf buffer, int precision, int scale) void
NullableDecimal38DenseWriter.writeDecimal38Dense
(int start, DrillBuf buffer, int precision, int scale) void
RepeatedDecimal38DenseWriter.writeDecimal38Dense
(int start, DrillBuf buffer, int precision, int scale) void
Decimal38SparseWriter.writeDecimal38Sparse
(int start, DrillBuf buffer, int precision, int scale) void
NullableDecimal38SparseWriter.writeDecimal38Sparse
(int start, DrillBuf buffer, int precision, int scale) void
RepeatedDecimal38SparseWriter.writeDecimal38Sparse
(int start, DrillBuf buffer, int precision, int scale) void
NullableVar16CharWriter.writeVar16Char
(int start, int end, DrillBuf buffer) void
RepeatedVar16CharWriter.writeVar16Char
(int start, int end, DrillBuf buffer) void
Var16CharWriter.writeVar16Char
(int start, int end, DrillBuf buffer) void
NullableVarBinaryWriter.writeVarBinary
(int start, int end, DrillBuf buffer) void
RepeatedVarBinaryWriter.writeVarBinary
(int start, int end, DrillBuf buffer) void
VarBinaryWriter.writeVarBinary
(int start, int end, DrillBuf buffer) void
NullableVarCharWriter.writeVarChar
(int start, int end, DrillBuf buffer) void
RepeatedVarCharWriter.writeVarChar
(int start, int end, DrillBuf buffer) void
VarCharWriter.writeVarChar
(int start, int end, DrillBuf buffer) void
NullableVarDecimalWriter.writeVarDecimal
(int start, int end, DrillBuf buffer, int precision, int scale) void
RepeatedVarDecimalWriter.writeVarDecimal
(int start, int end, DrillBuf buffer, int precision, int scale) void
VarDecimalWriter.writeVarDecimal
(int start, int end, DrillBuf buffer, int precision, int scale) -
Uses of DrillBuf in org.apache.drill.exec.work.filter
Modifier and TypeMethodDescriptionBloomFilter.getContent()
DrillBuf[]
RuntimeFilterWritable.getData()
ModifierConstructorDescriptionBloomFilter
(DrillBuf byteBuf) RuntimeFilterWritable
(BitData.RuntimeFilterBDef runtimeFilterBDef, DrillBuf... data)