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) |
Constructor and Description |
---|
HttpdLogRecord(DrillBuf managedBuffer,
String timeFormat) |
HttpdParser(org.apache.drill.exec.vector.complex.writer.BaseWriter.MapWriter mapWriter,
DrillBuf managedBuffer,
String logFormat,
String timestampFormat,
Map<String,String> fieldMapping) |
Modifier and Type | Method and Description |
---|---|
void |
MessageReader.init(DrillBuf buf,
List<SchemaPath> columns,
VectorContainerWriter writer,
ReadOptions readOptions) |
void |
JsonMessageReader.init(DrillBuf buf,
List<SchemaPath> columns,
VectorContainerWriter writer,
ReadOptions readOptions) |
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 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.