| Modifier and Type | Field and Description |
|---|---|
DrillBuf |
DrillBuf.TransferResult.buffer
The newly created buffer associated with the target allocator.
|
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
DrillBuf.capacity(int newCapacity) |
DrillBuf |
DrillBuf.duplicate() |
DrillBuf |
DrillBuf.reallocIfNeeded(int size) |
DrillBuf |
DrillBuf.retain(BufferAllocator target)
Create a new DrillBuf that is associated with an alternative allocator for
the purposes of memory ownership and accounting.
|
DrillBuf |
DrillBuf.slice(int index,
int length) |
| Modifier and Type | Method and Description |
|---|---|
Map<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 Type | Method and Description |
|---|---|
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) |
org.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.
|
| Modifier and Type | Method and Description |
|---|---|
static DrillBuf |
MappifyUtility.mappify(FieldReader reader,
org.apache.drill.exec.vector.complex.writer.BaseWriter.ComplexWriter writer,
DrillBuf buffer,
String caller) |
| Modifier and Type | Method and Description |
|---|---|
static 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 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 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 DrillBuffers
|
static long |
StringFunctionHelpers.getDate(DrillBuf buf,
int start,
int end) |
static int |
XXHash.hash32(int start,
int end,
DrillBuf buffer,
int seed) |
static int |
MurmurHash3.hash32(int start,
int end,
DrillBuf buffer,
int seed) |
static int |
HashHelper.hash32(int start,
int end,
DrillBuf buffer,
int seed) |
static long |
XXHash.hash64(long start,
long end,
DrillBuf buffer,
long seed) |
static long |
MurmurHash3.hash64(long start,
long end,
DrillBuf buffer,
long seed) |
static long |
HashHelper.hash64(long start,
long end,
DrillBuf buffer,
long seed) |
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,
org.apache.drill.exec.vector.complex.writer.BaseWriter.ComplexWriter writer,
DrillBuf buffer,
String caller) |
int |
SqlPatternEndsWithMatcher.match(int start,
int end,
DrillBuf drillBuf) |
int |
SqlPatternComplexMatcher.match(int start,
int end,
DrillBuf drillBuf) |
int |
SqlPatternConstantMatcher.match(int start,
int end,
DrillBuf drillBuf) |
int |
SqlPatternStartsWithMatcher.match(int start,
int end,
DrillBuf drillBuf) |
int |
SqlPatternContainsMatcher.match(int start,
int end,
DrillBuf drillBuf) |
int |
SqlPatternMatcher.match(int start,
int end,
DrillBuf drillBuf) |
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 |
CharSequenceWrapper.setBuffer(int start,
int end,
DrillBuf buffer)
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) |
| Constructor and Description |
|---|
CharSequenceWrapper(int start,
int end,
DrillBuf buffer) |
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
AllocationReservation.allocateBuffer()
Allocate a buffer whose size is the total of all the add()s made.
|
DrillBuf |
BaseAllocator.Reservation.allocateBuffer() |
DrillBuf |
BaseAllocator.buffer(int initialRequestSize) |
DrillBuf |
BufferAllocator.buffer(int size)
Allocate a new or reused buffer of the provided size.
|
DrillBuf |
BaseAllocator.buffer(int initialRequestSize,
BufferManager manager) |
DrillBuf |
BufferAllocator.buffer(int size,
BufferManager manager)
Allocate a new or reused buffer of the provided size.
|
DrillBuf |
BaseAllocator.getEmpty() |
DrillBuf |
BufferAllocator.getEmpty()
Get a reference to the empty buffer associated with this allocator.
|
DrillBuf |
AllocationManager.BufferLedger.newDrillBuf(int offset,
int length)
Create a new DrillBuf associated with this AllocationManager and memory.
|
DrillBuf |
AllocationManager.BufferLedger.newDrillBuf(int offset,
int length,
BufferManager manager)
Create a new DrillBuf associated with this AllocationManager and memory.
|
DrillBuf |
BaseAllocator.read(int length,
InputStream in) |
DrillBuf |
BufferAllocator.read(int length,
InputStream in)
Reads the specified number of bytes into a new Drillbuf.
|
| Modifier and Type | Method and Description |
|---|---|
static 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 |
BufferAllocator.write(DrillBuf buf,
int length,
OutputStream out)
Write the contents of a DrillBuf to a stream.
|
void |
BaseAllocator.write(DrillBuf buf,
OutputStream out) |
void |
BufferAllocator.write(DrillBuf buf,
OutputStream out)
Write the contents of a DrillBuf to a stream.
|
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
BaseFragmentContext.getManagedBuffer() |
DrillBuf |
QueryContext.getManagedBuffer() |
DrillBuf |
FragmentContext.getManagedBuffer() |
DrillBuf |
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.
|
DrillBuf |
BufferManagerImpl.getManagedBuffer() |
DrillBuf |
OperatorContext.getManagedBuffer() |
DrillBuf |
FragmentContextInterface.getManagedBuffer() |
DrillBuf |
BaseOperatorContext.getManagedBuffer() |
DrillBuf |
BufferManager.getManagedBuffer()
Get a managed buffer of indeterminate size.
|
DrillBuf |
BaseFragmentContext.getManagedBuffer(int size) |
DrillBuf |
FragmentContext.getManagedBuffer(int size) |
DrillBuf |
BufferManagerImpl.getManagedBuffer(int size) |
DrillBuf |
OperatorContext.getManagedBuffer(int size) |
DrillBuf |
FragmentContextInterface.getManagedBuffer(int size) |
DrillBuf |
BaseOperatorContext.getManagedBuffer(int size) |
DrillBuf |
BufferManager.getManagedBuffer(int size)
Get a managed buffer of at least a certain size.
|
DrillBuf |
BaseFragmentContext.replace(DrillBuf old,
int newSize) |
DrillBuf |
FragmentContext.replace(DrillBuf old,
int newSize) |
DrillBuf |
BufferManagerImpl.replace(DrillBuf old,
int newSize) |
DrillBuf |
OperatorContext.replace(DrillBuf old,
int newSize) |
DrillBuf |
FragmentContextInterface.replace(DrillBuf old,
int newSize) |
DrillBuf |
BaseOperatorContext.replace(DrillBuf old,
int newSize) |
DrillBuf |
BufferManager.replace(DrillBuf old,
int newSize)
Replace an old buffer with a new version at least of the provided size.
|
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
BaseFragmentContext.replace(DrillBuf old,
int newSize) |
DrillBuf |
FragmentContext.replace(DrillBuf old,
int newSize) |
DrillBuf |
BufferManagerImpl.replace(DrillBuf old,
int newSize) |
DrillBuf |
OperatorContext.replace(DrillBuf old,
int newSize) |
DrillBuf |
FragmentContextInterface.replace(DrillBuf old,
int newSize) |
DrillBuf |
BaseOperatorContext.replace(DrillBuf old,
int newSize) |
DrillBuf |
BufferManager.replace(DrillBuf old,
int newSize)
Replace an old buffer with a new version at least of the provided size.
|
| Modifier and Type | Method and Description |
|---|---|
ValueHolder |
FragmentContextImpl.getConstantValueHolder(String value,
TypeProtos.MinorType type,
org.apache.drill.shaded.guava.com.google.common.base.Function<DrillBuf,ValueHolder> holderInitializer) |
ValueHolder |
QueryContext.getConstantValueHolder(String value,
TypeProtos.MinorType type,
org.apache.drill.shaded.guava.com.google.common.base.Function<DrillBuf,ValueHolder> holderInitializer) |
ValueHolder |
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.
|
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
OutputMutator.getManagedBuffer()
Allows a scanner to request a set of managed block of memory.
|
DrillBuf |
ScanBatch.Mutator.getManagedBuffer() |
| Constructor and Description |
|---|
HivePartitionDescriptor(PlannerSettings settings,
DrillScanRel scanRel,
DrillBuf managedBuffer,
String defaultPartitionValue) |
| Modifier and Type | Field and Description |
|---|---|
static DrillBuf |
DeadBuf.DEAD_BUFFER |
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
RawFragmentBatch.getBody() |
DrillBuf[] |
WritableBatch.getBuffers() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
RecordBatchLoader.load(UserBitShared.RecordBatchDef def,
DrillBuf buf)
Load a record batch from a single buffer.
|
| Constructor and Description |
|---|
RawFragmentBatch(BitData.FragmentRecordBatch header,
DrillBuf body,
AckSender sender) |
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
SelectionVector2.getBuffer() |
DrillBuf |
SelectionVector2.getBuffer(boolean clear) |
| Modifier and Type | Method and Description |
|---|---|
void |
SelectionVector2.setBuffer(DrillBuf bufferHandle) |
| Constructor and Description |
|---|
SelectionVector2(BufferAllocator allocator,
DrillBuf buf,
int count)
Create a selection vector with the given buffer.
|
SelectionVector2(BufferAllocator allocator,
DrillBuf buf,
int count,
int actualRecordCount) |
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
ControlTunnel.CustomFuture.getBuffer() |
| Modifier and Type | Method and Description |
|---|---|
Response |
CustomHandlerRegistry.handle(BitControl.CustomMessage message,
DrillBuf dBody) |
Controller.CustomResponse<RESPONSE> |
Controller.CustomMessageHandler.onMessage(REQUEST pBody,
DrillBuf dBody)
Handle an incoming message.
|
| Constructor and Description |
|---|
IncomingDataBatch(BitData.FragmentRecordBatch header,
DrillBuf body,
AckSender sender)
Create a new batch.
|
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
QueryDataBatch.getData() |
| Constructor and Description |
|---|
QueryDataBatch(UserBitShared.QueryData header,
DrillBuf data) |
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
TestOutputMutator.getManagedBuffer() |
| Modifier and Type | Field and Description |
|---|---|
protected DrillBuf |
BsonRecordReader.workBuf |
| Constructor and Description |
|---|
BsonRecordReader(DrillBuf managedBuf,
boolean allTextMode,
boolean readNumbersAsDouble) |
BsonRecordReader(DrillBuf managedBuf,
List<SchemaPath> columns,
boolean readNumbersAsDouble) |
| Modifier and Type | Field and Description |
|---|---|
protected DrillBuf |
BaseJsonProcessor.workBuf |
| Constructor and Description |
|---|
BaseJsonProcessor(DrillBuf workBuf,
boolean enableNanInf,
boolean enableEscapeAnyChar) |
BaseJsonReader(DrillBuf workBuf,
boolean enableNanInf,
boolean enableEscapeAnyChar,
boolean skipOuterList) |
CountingJsonReader(DrillBuf workBuf,
boolean enableNanInf,
boolean enableEscapeAnyChar) |
| Constructor and Description |
|---|
TextReader(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 by
TextParsingSettings,
and requires this configuration to be properly initialized. |
| Modifier and Type | Method and Description |
|---|---|
static void |
HiveUtilities.populateVector(ValueVector vector,
DrillBuf managedBuffer,
Object val,
int start,
int end)
Populates vector with given value based on its type.
|
| Constructor and Description |
|---|
HiveValueWriterFactory(DrillBuf drillBuf,
org.apache.drill.exec.vector.complex.impl.SingleMapWriter rootWriter) |
| Constructor and Description |
|---|
HiveBinaryWriter(org.apache.hadoop.hive.serde2.objectinspector.primitive.BinaryObjectInspector inspector,
org.apache.drill.exec.vector.complex.writer.VarBinaryWriter writer,
DrillBuf drillBuf) |
HiveCharWriter(org.apache.hadoop.hive.serde2.objectinspector.primitive.HiveCharObjectInspector inspector,
org.apache.drill.exec.vector.complex.writer.VarCharWriter writer,
DrillBuf drillBuf) |
HiveStringWriter(org.apache.hadoop.hive.serde2.objectinspector.primitive.StringObjectInspector inspector,
org.apache.drill.exec.vector.complex.writer.VarCharWriter writer,
DrillBuf drillBuf) |
HiveVarCharWriter(org.apache.hadoop.hive.serde2.objectinspector.primitive.HiveVarcharObjectInspector inspector,
org.apache.drill.exec.vector.complex.writer.VarCharWriter writer,
DrillBuf drillBuf) |
| Modifier and Type | Field and Description |
|---|---|
protected DrillBuf |
OjaiValueWriter.buffer |
| Constructor and Description |
|---|
AllTextValueWriter(DrillBuf buffer) |
NumbersAsDoubleValueWriter(DrillBuf buffer) |
OjaiValueWriter(DrillBuf buffer) |
| Modifier and Type | Method and Description |
|---|---|
void |
ColumnDataReader.loadPage(DrillBuf target,
int pageLength) |
| Modifier and Type | Field and Description |
|---|---|
protected DrillBuf |
ColumnReader.vectorData |
| Modifier and Type | Method and Description |
|---|---|
static int |
ColumnReader.readIntLittleEndian(DrillBuf in,
int offset) |
abstract boolean |
VarLengthValuesColumn.setSafe(int index,
DrillBuf bytes,
int start,
int length)
Store a variable length entry if there is enough memory.
|
boolean |
VarLengthColumnReaders.VarDecimalColumn.setSafe(int index,
DrillBuf value,
int start,
int length) |
boolean |
VarLengthColumnReaders.NullableVarDecimalColumn.setSafe(int index,
DrillBuf value,
int start,
int length) |
boolean |
VarLengthColumnReaders.VarCharColumn.setSafe(int index,
DrillBuf bytebuf,
int start,
int length) |
boolean |
VarLengthColumnReaders.NullableVarCharColumn.setSafe(int index,
DrillBuf value,
int start,
int length) |
boolean |
VarLengthColumnReaders.VarBinaryColumn.setSafe(int index,
DrillBuf value,
int start,
int length) |
boolean |
VarLengthColumnReaders.NullableVarBinaryColumn.setSafe(int index,
DrillBuf value,
int start,
int length) |
abstract boolean |
NullableVarLengthValuesColumn.setSafe(int index,
DrillBuf value,
int start,
int length) |
| Modifier and Type | Field and Description |
|---|---|
DrillBuf |
RecordBatchOverflow.FieldOverflowDefinition.buffer
DrillBuf where the serialized data is stored
|
| Modifier and Type | Method and Description |
|---|---|
void |
Int64DecimalParquetValueWriter.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 |
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 specified
DrillBuf buffer, converts it into required format
if needed and passes the value into specified RecordConsumer consumer. |
void |
FixedLenDecimalParquetValueWriter.writeValue(org.apache.parquet.io.api.RecordConsumer consumer,
DrillBuf buffer,
int start,
int end,
int precision) |
| Constructor and Description |
|---|
DrillFixedBinaryToVarbinaryConverter(org.apache.drill.exec.vector.complex.writer.VarBinaryWriter writer,
int length,
DrillBuf buf) |
DrillVarBinaryConverter(org.apache.drill.exec.vector.complex.writer.VarBinaryWriter writer,
DrillBuf buf) |
DrillVarCharConverter(org.apache.drill.exec.vector.complex.writer.VarCharWriter writer,
DrillBuf buf) |
DrillVarDecimalConverter(org.apache.drill.exec.vector.complex.writer.VarDecimalWriter writer,
int precision,
int scale,
DrillBuf buf) |
| Modifier and Type | Method and Description |
|---|---|
static PojoWriter |
PojoWriters.getWriter(Class<?> type,
String fieldName,
DrillBuf buffer)
Creates matching writer to the given field type.
|
| Constructor and Description |
|---|
EnumWriter(String fieldName,
DrillBuf managedBuf) |
StringWriter(String fieldName,
DrillBuf managedBuf) |
| Modifier and Type | Method and Description |
|---|---|
static DrillBuf |
ComplexSchemaUtils.getFields(FieldReader reader,
org.apache.drill.exec.vector.complex.writer.BaseWriter.ComplexWriter outWriter,
DrillBuf buffer) |
| Modifier and Type | Method and Description |
|---|---|
static DrillBuf |
ComplexSchemaUtils.getFields(FieldReader reader,
org.apache.drill.exec.vector.complex.writer.BaseWriter.ComplexWriter outWriter,
DrillBuf buffer) |
| Modifier and Type | Method and Description |
|---|---|
static 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 array
|
static 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 buffers
|
static 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 |
ByteBufUtil.HadoopWritables.readVInt(DrillBuf buffer,
int start,
int end)
Reads a zero-compressed encoded integer from input stream and returns it.
|
static long |
ByteBufUtil.HadoopWritables.readVLong(DrillBuf buffer,
int start,
int end)
Reads a zero-compressed encoded long from input stream and returns it.
|
static void |
ByteBufUtil.HadoopWritables.writeVInt(DrillBuf buffer,
int start,
int end,
int i)
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.
|
| Modifier and Type | Field and Description |
|---|---|
protected DrillBuf |
BufferedDirectBufInputStream.internalBuffer
The internal buffer to keep data read from the underlying inputStream.
|
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
DirectBufInputStream.getNext(int bytes) |
| Modifier and Type | Method and Description |
|---|---|
int |
BufferedDirectBufInputStream.read(DrillBuf buf,
int off,
int len)
Has the same contract as
InputStream.read(byte[], int, int)
Except with DrillBuf |
int |
DirectBufInputStream.read(DrillBuf buf,
int off,
int len) |
| Modifier and Type | Field and Description |
|---|---|
protected DrillBuf |
BaseDataValueVector.data |
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
BaseDataValueVector.getBuffer() |
DrillBuf[] |
ValueVector.getBuffers(boolean clear)
Return the underlying buffers associated with this vector.
|
DrillBuf[] |
BaseDataValueVector.getBuffers(boolean clear) |
DrillBuf[] |
ObjectVector.getBuffers(boolean clear) |
DrillBuf[] |
ZeroVector.getBuffers(boolean clear) |
DrillBuf |
VarLenBulkEntry.getData() |
DrillBuf |
UntypedNullVector.reallocRaw(int newAllocationSize) |
abstract DrillBuf |
BaseDataValueVector.reallocRaw(int newAllocationSize)
Core of vector allocation.
|
DrillBuf |
BitVector.reallocRaw(int newAllocationSize) |
| Modifier and Type | Method and Description |
|---|---|
static org.apache.drill.exec.expr.holders.Decimal28SparseHolder |
ValueHolderHelper.getDecimal28Holder(DrillBuf buf,
BigDecimal bigDecimal) |
static org.apache.drill.exec.expr.holders.Decimal28SparseHolder |
ValueHolderHelper.getDecimal28Holder(DrillBuf buf,
String decimal) |
static org.apache.drill.exec.expr.holders.Decimal38SparseHolder |
ValueHolderHelper.getDecimal38Holder(DrillBuf buf,
BigDecimal bigDecimal) |
static org.apache.drill.exec.expr.holders.Decimal38SparseHolder |
ValueHolderHelper.getDecimal38Holder(DrillBuf buf,
String decimal) |
static org.apache.drill.exec.expr.holders.VarCharHolder |
ValueHolderHelper.getVarCharHolder(DrillBuf buf,
String s) |
static org.apache.drill.exec.expr.holders.VarDecimalHolder |
ValueHolderHelper.getVarDecimalHolder(DrillBuf buf,
BigDecimal bigDecimal) |
static org.apache.drill.exec.expr.holders.VarDecimalHolder |
ValueHolderHelper.getVarDecimalHolder(DrillBuf buf,
String decimal) |
void |
UntypedNullVector.load(UserBitShared.SerializedField metadata,
DrillBuf buffer) |
void |
ValueVector.load(UserBitShared.SerializedField metadata,
DrillBuf buffer)
Load the data provided in the buffer.
|
void |
BitVector.load(UserBitShared.SerializedField metadata,
DrillBuf buffer) |
void |
ObjectVector.load(UserBitShared.SerializedField metadata,
DrillBuf buffer) |
void |
ZeroVector.load(UserBitShared.SerializedField metadata,
DrillBuf buffer) |
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
BaseScalarReader.buffer() |
DrillBuf |
BaseScalarReader.BufferAccessor.buffer() |
| Modifier and Type | Field and Description |
|---|---|
protected DrillBuf |
BaseScalarWriter.drillBuf |
| Modifier and Type | Method and Description |
|---|---|
DrillBuf[] |
RepeatedListVector.getBuffers(boolean clear) |
DrillBuf[] |
ListVector.getBuffers(boolean clear) |
DrillBuf[] |
BaseRepeatedValueVector.getBuffers(boolean clear) |
DrillBuf[] |
AbstractMapVector.getBuffers(boolean clear) |
DrillBuf[] |
AbstractRepeatedMapVector.getBuffers(boolean clear) |
DrillBuf[] |
MapVector.getBuffers(boolean clear) |
| Modifier and Type | Method and Description |
|---|---|
void |
RepeatedListVector.load(UserBitShared.SerializedField metadata,
DrillBuf buf) |
void |
ListVector.load(UserBitShared.SerializedField metadata,
DrillBuf buffer) |
void |
BaseRepeatedValueVector.load(UserBitShared.SerializedField metadata,
DrillBuf buffer) |
void |
AbstractRepeatedMapVector.load(UserBitShared.SerializedField metadata,
DrillBuf buffer) |
void |
MapVector.load(UserBitShared.SerializedField metadata,
DrillBuf buf) |
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
JsonReader.getWorkBuf() |
| Modifier and Type | Method and Description |
|---|---|
static DrillBufInputStream |
DrillBufInputStream.getStream(int start,
int end,
DrillBuf buffer) |
void |
JsonReader.setSource(int start,
int end,
DrillBuf buf) |
| Constructor and Description |
|---|
Builder(DrillBuf managedBuf) |
| Modifier and Type | Method and Description |
|---|---|
DrillBuf |
BloomFilter.getContent() |
DrillBuf[] |
RuntimeFilterWritable.getData() |
| Modifier and Type | Method and Description |
|---|---|
void |
RuntimeFilterWritable.setData(DrillBuf... data) |
| Constructor and Description |
|---|
BloomFilter(DrillBuf byteBuf) |
RuntimeFilterWritable(BitData.RuntimeFilterBDef runtimeFilterBDef,
DrillBuf... data) |
| Modifier and Type | Method and Description |
|---|---|
ValueHolder |
OperatorFixture.MockFragmentContext.getConstantValueHolder(String value,
TypeProtos.MinorType type,
org.apache.drill.shaded.guava.com.google.common.base.Function<DrillBuf,ValueHolder> holderInitializer) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.