Uses of Interface
org.apache.drill.exec.memory.BufferAllocator

Packages that use BufferAllocator

Package	Description
io.netty.buffer
org.apache.drill.exec.cache	Distributed cache for syncing state and data between Drillbits.
org.apache.drill.exec.client	Java client API for submitting queries and accepting result sets from a Drill server.
org.apache.drill.exec.memory	Memory Allocation, Account and Management See the README.md file in this directory for detailed information about Drill's memory allocation subsystem.
org.apache.drill.exec.ops
org.apache.drill.exec.physical.impl
org.apache.drill.exec.physical.impl.aggregate
org.apache.drill.exec.physical.impl.common
org.apache.drill.exec.physical.impl.join
org.apache.drill.exec.physical.impl.partitionsender
org.apache.drill.exec.physical.impl.scan.project	Provides run-time semantic analysis of the projection list for the scan operator.
org.apache.drill.exec.physical.impl.scan.v3.lifecycle	Implements the details of the scan lifecycle for a set of readers, primarily the process of resolving the scan output schema from a variety of input schemas, then running each reader, each of which will produce some number of batches.
org.apache.drill.exec.physical.impl.sort
org.apache.drill.exec.physical.impl.svremover
org.apache.drill.exec.physical.impl.TopN
org.apache.drill.exec.physical.impl.xsort
org.apache.drill.exec.physical.resultSet	Provides a second-generation row set (AKA "record batch") writer used by client code to Define the schema of a result set. Write data into the vectors backing a row set.
org.apache.drill.exec.physical.resultSet.impl	Handles the details of the result set loader implementation.
org.apache.drill.exec.physical.resultSet.model.single	This set of classes models the structure of a batch consisting of single vectors (as contrasted with a hyper batch.) Provides tools or metdata-based construction, allocation, reading and writing of the vectors.
org.apache.drill.exec.physical.rowSet	Provides a set of tools to work with row sets.
org.apache.drill.exec.record
org.apache.drill.exec.record.selection
org.apache.drill.exec.rpc
org.apache.drill.exec.rpc.control
org.apache.drill.exec.rpc.data
org.apache.drill.exec.rpc.user
org.apache.drill.exec.server
org.apache.drill.exec.server.rest
org.apache.drill.exec.ssl
org.apache.drill.exec.store
org.apache.drill.exec.store.easy.text.writer
org.apache.drill.exec.store.parquet
org.apache.drill.exec.store.parquet.columnreaders.batchsizing
org.apache.drill.exec.util.filereader
org.apache.drill.exec.util.record
org.apache.drill.exec.vector
org.apache.drill.exec.vector.complex
org.apache.drill.exec.work.batch
org.apache.drill.exec.work.filter
org.apache.drill.test	Provides a variety of test framework tools to simplify Drill unit tests and ad-hoc tests created while developing features.
org.apache.parquet.hadoop

Uses of BufferAllocator in io.netty.buffer

Methods in io.netty.buffer with parameters of type BufferAllocator

Modifier and Type	Method and Description
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.TransferResult	DrillBuf.transferOwnership(BufferAllocator target) Transfer the memory accounting ownership of this DrillBuf to another allocator.

Constructors in io.netty.buffer with parameters of type BufferAllocator

Constructor and Description
ExpandableByteBuf(io.netty.buffer.ByteBuf buffer, BufferAllocator allocator)

Uses of BufferAllocator in org.apache.drill.exec.cache

Methods in org.apache.drill.exec.cache with parameters of type BufferAllocator

Modifier and Type	Method and Description
static VectorSerializer.Reader	VectorSerializer.reader(BufferAllocator allocator, InputStream stream)

Constructors in org.apache.drill.exec.cache with parameters of type BufferAllocator

Constructor and Description
CachedVectorContainer(BufferAllocator allocator)
CachedVectorContainer(byte[] data, BufferAllocator allocator)
CachedVectorContainer(WritableBatch batch, BufferAllocator allocator)
Reader(BufferAllocator allocator, InputStream stream)
VectorAccessibleSerializable(BufferAllocator allocator)
VectorAccessibleSerializable(WritableBatch batch, BufferAllocator allocator)
VectorAccessibleSerializable(WritableBatch batch, SelectionVector2 sv2, BufferAllocator allocator) Creates a wrapper around batch and sv2 for writing to a stream.

Uses of BufferAllocator in org.apache.drill.exec.client

Methods in org.apache.drill.exec.client that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	DrillClient.getAllocator()

Constructors in org.apache.drill.exec.client with parameters of type BufferAllocator

Constructor and Description
DrillClient(DrillConfig config, ClusterCoordinator coordinator, BufferAllocator allocator)
DrillClient(DrillConfig config, ClusterCoordinator coordinator, BufferAllocator allocator, boolean isDirect)

Uses of BufferAllocator in org.apache.drill.exec.memory

Classes in org.apache.drill.exec.memory that implement BufferAllocator

Modifier and Type	Class and Description
class	BaseAllocator
class	RootAllocator The root allocator for using direct memory inside a Drillbit.

Methods in org.apache.drill.exec.memory that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	BaseAllocator.newChildAllocator(String name, long initReservation, long maxAllocation)
BufferAllocator	BufferAllocator.newChildAllocator(String name, long initReservation, long maxAllocation) Create a new child allocator.
static BufferAllocator	RootAllocatorFactory.newRoot(DrillConfig drillConfig) Create a new Root Allocator
static BufferAllocator	RootAllocatorFactory.newRoot(long maxAlloc)

Methods in org.apache.drill.exec.memory with parameters of type BufferAllocator

Modifier and Type	Method and Description
AllocationManager.BufferLedger	AllocationManager.BufferLedger.getLedgerForAllocator(BufferAllocator allocator) Returns the ledger associated with a particular BufferAllocator.

Constructors in org.apache.drill.exec.memory with parameters of type BufferAllocator

Constructor and Description
DrillByteBufAllocator(BufferAllocator allocator)

Uses of BufferAllocator in org.apache.drill.exec.ops

Fields in org.apache.drill.exec.ops declared as BufferAllocator

Modifier and Type	Field and Description
protected BufferAllocator	BaseOperatorContext.allocator

Methods in org.apache.drill.exec.ops that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	FragmentContextImpl.getAllocator() Deprecated.
BufferAllocator	QueryContext.getAllocator()
BufferAllocator	FragmentContext.getAllocator()
BufferAllocator	OperatorContext.getAllocator() Return the memory allocator for this operator.
BufferAllocator	BaseOperatorContext.getAllocator()
BufferAllocator	OptimizerRulesContext.getAllocator() Method returns the allocator
BufferAllocator	FragmentContextImpl.getNewChildAllocator(String operatorName, int operatorId, long initialReservation, long maximumReservation)
BufferAllocator	FragmentContext.getNewChildAllocator(String operatorName, int operatorId, long initialReservation, long maximumReservation)
BufferAllocator	FragmentContextImpl.getRootAllocator()
BufferAllocator	ExecutorFragmentContext.getRootAllocator() Returns the root allocator for the Drillbit.

Methods in org.apache.drill.exec.ops with parameters of type BufferAllocator

Modifier and Type	Method and Description
OperatorStats	FragmentStats.newOperatorStats(OpProfileDef profileDef, BufferAllocator allocator) Creates a new holder for operator statistics within this holder for fragment statistics.

Constructors in org.apache.drill.exec.ops with parameters of type BufferAllocator

Constructor and Description
BaseOperatorContext(FragmentContext context, BufferAllocator allocator, PhysicalOperator popConfig)
BufferManagerImpl(BufferAllocator allocator)
FragmentStats(BufferAllocator allocator, CoordinationProtos.DrillbitEndpoint endpoint)
OperatorStats(int operatorId, String operatorType, int inputCount, BufferAllocator allocator)
OperatorStats(OpProfileDef def, BufferAllocator allocator)

Uses of BufferAllocator in org.apache.drill.exec.physical.impl

Fields in org.apache.drill.exec.physical.impl declared as BufferAllocator

Modifier and Type	Field and Description
protected BufferAllocator	MockRecordBatch.allocator

Constructors in org.apache.drill.exec.physical.impl with parameters of type BufferAllocator

Constructor and Description
Mutator(OperatorContext oContext, BufferAllocator allocator, VectorContainer container)

Uses of BufferAllocator in org.apache.drill.exec.physical.impl.aggregate

Constructors in org.apache.drill.exec.physical.impl.aggregate with parameters of type BufferAllocator

Constructor and Description
HashAggUpdater(BufferAllocator allocator)

Uses of BufferAllocator in org.apache.drill.exec.physical.impl.common

Methods in org.apache.drill.exec.physical.impl.common with parameters of type BufferAllocator

Modifier and Type	Method and Description
void	HashTableTemplate.setup(HashTableConfig htConfig, BufferAllocator allocator, VectorContainer incomingBuild, RecordBatch incomingProbe, RecordBatch outgoing, VectorContainer htContainerOrig, FragmentContext context, ClassGenerator<?> cg)
void	HashTable.setup(HashTableConfig htConfig, BufferAllocator allocator, VectorContainer incomingBuild, RecordBatch incomingProbe, RecordBatch outgoing, VectorContainer htContainerOrig, FragmentContext context, ClassGenerator<?> cg) HashTable.setup(org.apache.drill.exec.physical.impl.common.HashTableConfig, org.apache.drill.exec.memory.BufferAllocator, org.apache.drill.exec.record.VectorContainer, org.apache.drill.exec.record.RecordBatch, org.apache.drill.exec.record.RecordBatch, org.apache.drill.exec.record.VectorContainer, org.apache.drill.exec.ops.FragmentContext, org.apache.drill.exec.expr.ClassGenerator<?>) must be called before anything can be done to the HashTable.

Constructors in org.apache.drill.exec.physical.impl.common with parameters of type BufferAllocator

Constructor and Description
ChainedHashTable(HashTableConfig htConfig, FragmentContext context, BufferAllocator allocator, RecordBatch incomingBuild, RecordBatch incomingProbe, RecordBatch outgoing)
HashPartition(FragmentContext context, BufferAllocator allocator, ChainedHashTable baseHashTable, RecordBatch buildBatch, RecordBatch probeBatch, boolean semiJoin, int recordsPerBatch, SpillSet spillSet, int partNum, int cycleNum, int numPartitions)

Uses of BufferAllocator in org.apache.drill.exec.physical.impl.join

Constructors in org.apache.drill.exec.physical.impl.join with parameters of type BufferAllocator

Constructor and Description
HashJoinHelper(FragmentContext context, BufferAllocator allocator)

Uses of BufferAllocator in org.apache.drill.exec.physical.impl.partitionsender

Methods in org.apache.drill.exec.physical.impl.partitionsender with parameters of type BufferAllocator

Modifier and Type	Method and Description
protected PartitionerTemplate.OutgoingRecordBatch	PartitionerTemplate.newOutgoingRecordBatch(OperatorStats stats, HashPartitionSender operator, AccountingDataTunnel tunnel, FragmentContext context, BufferAllocator allocator, int oppositeMinorFragmentId) Shim method to be overridden in plain-old Java mode by the subclass to instantiate the generated inner class.

Constructors in org.apache.drill.exec.physical.impl.partitionsender with parameters of type BufferAllocator

Constructor and Description
OutgoingRecordBatch(OperatorStats stats, HashPartitionSender operator, AccountingDataTunnel tunnel, FragmentContext context, BufferAllocator allocator, int oppositeMinorFragmentId)

Uses of BufferAllocator in org.apache.drill.exec.physical.impl.scan.project

Fields in org.apache.drill.exec.physical.impl.scan.project declared as BufferAllocator

Modifier and Type	Field and Description
protected BufferAllocator	ScanSchemaOrchestrator.allocator

Methods in org.apache.drill.exec.physical.impl.scan.project that return BufferAllocator

Modifier and Type	Method and Description
abstract BufferAllocator	ResolvedTuple.allocator()
BufferAllocator	ResolvedTuple.ResolvedRow.allocator()
BufferAllocator	ResolvedTuple.ResolvedMap.allocator()
BufferAllocator	ResolvedTuple.ResolvedSingleDict.allocator()
BufferAllocator	ResolvedTuple.ResolvedDictArray.allocator()

Methods in org.apache.drill.exec.physical.impl.scan.project with parameters of type BufferAllocator

Modifier and Type	Method and Description
protected abstract AbstractMapVector	ResolvedTuple.ResolvedMap.createMap(AbstractMapVector inputMap, MaterializedField create, BufferAllocator allocator)
protected AbstractMapVector	ResolvedTuple.ResolvedSingleMap.createMap(AbstractMapVector inputMap, MaterializedField schema, BufferAllocator allocator)
protected AbstractMapVector	ResolvedTuple.ResolvedMapArray.createMap(AbstractMapVector inputMap, MaterializedField schema, BufferAllocator allocator)

Constructors in org.apache.drill.exec.physical.impl.scan.project with parameters of type BufferAllocator

Constructor and Description
ScanSchemaOrchestrator(BufferAllocator allocator, ScanSchemaOrchestrator.ScanOrchestratorBuilder builder)

Uses of BufferAllocator in org.apache.drill.exec.physical.impl.scan.v3.lifecycle

Methods in org.apache.drill.exec.physical.impl.scan.v3.lifecycle that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	ScanLifecycle.allocator()

Constructors in org.apache.drill.exec.physical.impl.scan.v3.lifecycle with parameters of type BufferAllocator

Constructor and Description
OutputBatchBuilder(TupleMetadata outputSchema, List<OutputBatchBuilder.BatchSource> sources, BufferAllocator allocator)

Uses of BufferAllocator in org.apache.drill.exec.physical.impl.sort

Constructors in org.apache.drill.exec.physical.impl.sort with parameters of type BufferAllocator

Constructor and Description
RecordBatchData(VectorAccessible batch, BufferAllocator allocator)
SortRecordBatchBuilder(BufferAllocator a)

Uses of BufferAllocator in org.apache.drill.exec.physical.impl.svremover

Methods in org.apache.drill.exec.physical.impl.svremover with parameters of type BufferAllocator

Modifier and Type	Method and Description
RowSet	AbstractGenericCopierTest.createExpectedRowset(BufferAllocator allocator)
RowSet	GenericSV4CopierTest.createSrcRowSet(BufferAllocator allocator)
RowSet	GenericCopierTest.createSrcRowSet(BufferAllocator allocator)
RowSet	GenericSV2CopierTest.createSrcRowSet(BufferAllocator allocator)
RowSet	GenericSV2BatchCopierTest.createSrcRowSet(BufferAllocator allocator)
abstract RowSet	AbstractGenericCopierTest.createSrcRowSet(BufferAllocator allocator)

Uses of BufferAllocator in org.apache.drill.exec.physical.impl.TopN

Methods in org.apache.drill.exec.physical.impl.TopN with parameters of type BufferAllocator

Modifier and Type	Method and Description
static PriorityQueue	TopNBatch.createNewPriorityQueue(MappingSet mainMapping, MappingSet leftMapping, MappingSet rightMapping, List<Order.Ordering> orderings, VectorAccessible batch, boolean unionTypeEnabled, boolean codegenDump, int limit, BufferAllocator allocator, BatchSchema.SelectionVectorMode mode, FragmentContext context)
void	PriorityQueue.init(int limit, BufferAllocator allocator, boolean hasSv2) Initializes the priority queue.
void	PriorityQueueTemplate.init(int limit, BufferAllocator allocator, boolean hasSv2)

Uses of BufferAllocator in org.apache.drill.exec.physical.impl.xsort

Fields in org.apache.drill.exec.physical.impl.xsort declared as BufferAllocator

Modifier and Type	Field and Description
protected BufferAllocator	BatchGroup.allocator

Methods in org.apache.drill.exec.physical.impl.xsort that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	PriorityQueueCopierWrapper.getAllocator()

Methods in org.apache.drill.exec.physical.impl.xsort with parameters of type BufferAllocator

Modifier and Type	Method and Description
void	PriorityQueueCopierTemplate.setup(BufferAllocator allocator, VectorAccessible hyperBatch, List<BatchGroup> batchGroups, VectorAccessible outgoing)
void	PriorityQueueCopier.setup(BufferAllocator allocator, VectorAccessible hyperBatch, List<BatchGroup> batchGroups, VectorAccessible outgoing)
void	MSorter.setup(FragmentContext context, BufferAllocator allocator, SelectionVector4 vector4, VectorContainer hyperBatch, int outputBatchSize, int desiredBatchSize)
void	MSortTemplate.setup(FragmentContext context, BufferAllocator allocator, SelectionVector4 vector4, VectorContainer hyperBatch, int outputBatchSize, int desiredBatchSize)

Constructors in org.apache.drill.exec.physical.impl.xsort with parameters of type BufferAllocator

Constructor and Description
BatchGroup(VectorContainer container, BufferAllocator allocator)
InputBatch(VectorContainer container, SelectionVector2 sv2, BufferAllocator allocator, long dataSize)
SpilledRun(SpillSet spillSet, String path, BufferAllocator allocator)

Uses of BufferAllocator in org.apache.drill.exec.physical.resultSet

Methods in org.apache.drill.exec.physical.resultSet that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	ResultVectorCache.allocator()

Uses of BufferAllocator in org.apache.drill.exec.physical.resultSet.impl

Methods in org.apache.drill.exec.physical.resultSet.impl that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	ResultVectorCacheImpl.allocator()
BufferAllocator	ResultSetLoaderImpl.allocator()
BufferAllocator	NullResultVectorCacheImpl.allocator()

Constructors in org.apache.drill.exec.physical.resultSet.impl with parameters of type BufferAllocator

Constructor and Description
NullResultVectorCacheImpl(BufferAllocator allocator)
ResultSetCopierImpl(BufferAllocator allocator, PullResultSetReader source)
ResultSetCopierImpl(BufferAllocator allocator, PullResultSetReader source, ResultSetOptionBuilder outputOptions)
ResultSetLoaderImpl(BufferAllocator allocator)
ResultSetLoaderImpl(BufferAllocator allocator, ResultSetLoaderImpl.ResultSetOptions options)
ResultVectorCacheImpl(BufferAllocator allocator)
ResultVectorCacheImpl(BufferAllocator allocator, boolean permissiveMode)

Uses of BufferAllocator in org.apache.drill.exec.physical.resultSet.model.single

Constructors in org.apache.drill.exec.physical.resultSet.model.single with parameters of type BufferAllocator

Constructor and Description
BuildVectorsFromMetadata(BufferAllocator allocator)

Uses of BufferAllocator in org.apache.drill.exec.physical.rowSet

Methods in org.apache.drill.exec.physical.rowSet that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	AbstractRowSet.allocator()
BufferAllocator	RowSet.allocator()

Methods in org.apache.drill.exec.physical.rowSet with parameters of type BufferAllocator

Modifier and Type	Method and Description
static RowSet.HyperRowSetBuilder	HyperRowSetImpl.builder(BufferAllocator allocator)
static RowSet	RowSetBuilder.emptyBatch(BufferAllocator allocator, TupleMetadata schema)
static RowSet.HyperRowSet	HyperRowSetImpl.fromRowSets(BufferAllocator allocator, RowSet.SingleRowSet... rowSets)
static DirectRowSet	DirectRowSet.fromSchema(BufferAllocator allocator, BatchSchema schema)
static DirectRowSet	DirectRowSet.fromSchema(BufferAllocator allocator, TupleMetadata schema)
static DirectRowSet	DirectRowSet.fromVectorAccessible(BufferAllocator allocator, VectorAccessible va)
static RowSetWriter	RowSetTestUtils.makeWriter(BufferAllocator allocator, TupleMetadata outputSchema)
static RowSetWriter	RowSetTestUtils.makeWriter(BufferAllocator allocator, TupleMetadata outputSchema, int size)

Constructors in org.apache.drill.exec.physical.rowSet with parameters of type BufferAllocator

Constructor and Description
HyperRowSetBuilderImpl(BufferAllocator allocator)
RowSetBuilder(BufferAllocator allocator, BatchSchema schema) Deprecated. Use RowSetBuilder.RowSetBuilder(BufferAllocator, TupleMetadata) instead.
RowSetBuilder(BufferAllocator allocator, TupleMetadata schema)
RowSetBuilder(BufferAllocator allocator, TupleMetadata schema, int capacity)

Uses of BufferAllocator in org.apache.drill.exec.record

Methods in org.apache.drill.exec.record that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	RecordBatchLoader.allocator()
BufferAllocator	VectorContainer.getAllocator()

Methods in org.apache.drill.exec.record with parameters of type BufferAllocator

Modifier and Type	Method and Description
VectorWrapper<T>	HyperVectorWrapper.cloneAndTransfer(BufferAllocator allocator)
VectorWrapper<T>	VectorWrapper.cloneAndTransfer(BufferAllocator allocator)
VectorWrapper<T>	SimpleVectorWrapper.cloneAndTransfer(BufferAllocator allocator)
static VectorContainer	SchemaUtil.coerceContainer(VectorAccessible in, BatchSchema toSchema, BufferAllocator allocator)
static VectorContainer	VectorContainer.getTransferClone(VectorAccessible incoming, BufferAllocator allocator)
void	WritableBatch.reconstructContainer(BufferAllocator allocator, VectorContainer container)
WritableBatch	WritableBatch.transfer(BufferAllocator allocator)

Constructors in org.apache.drill.exec.record with parameters of type BufferAllocator

Constructor and Description
RecordBatchLoader(BufferAllocator allocator) Constructs a loader using the given allocator for vector buffer allocation.
VectorContainer(BufferAllocator allocator)
VectorContainer(BufferAllocator allocator, BatchSchema schema) Create a new vector container given a pre-defined schema.

Uses of BufferAllocator in org.apache.drill.exec.record.selection

Constructors in org.apache.drill.exec.record.selection with parameters of type BufferAllocator

Constructor and Description
SelectionVector2(BufferAllocator allocator)
SelectionVector2(BufferAllocator allocator, DrillBuf buf, int count) Create a selection vector with the given buffer.
SelectionVector2(BufferAllocator allocator, DrillBuf buf, int count, int actualRecordCount)
SelectionVector2Builder(BufferAllocator allocator, int maxSize)
SelectionVector4(BufferAllocator allocator, int recordCount)

Uses of BufferAllocator in org.apache.drill.exec.rpc

Methods in org.apache.drill.exec.rpc that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	AbstractConnectionConfig.getAllocator()
BufferAllocator	AbstractServerConnection.getAllocator()
BufferAllocator	ConnectionConfig.getAllocator()
BufferAllocator	RemoteConnection.getAllocator()

Methods in org.apache.drill.exec.rpc with parameters of type BufferAllocator

Modifier and Type	Method and Description
abstract ProtobufLengthDecoder	BasicClient.getDecoder(BufferAllocator allocator)
protected abstract ProtobufLengthDecoder	BasicServer.getDecoder(BufferAllocator allocator, OutOfMemoryHandler outOfMemoryHandler)
abstract void	AbstractRpcMetrics.initialize(boolean useEncryptedCounter, BufferAllocator allocator)
protected void	AbstractRpcMetrics.registerAllocatorMetrics(BufferAllocator allocator, String metricPrefix)

Constructors in org.apache.drill.exec.rpc with parameters of type BufferAllocator

Constructor and Description
AbstractConnectionConfig(BufferAllocator allocator, BootStrapContext context)
BitConnectionConfig(BufferAllocator allocator, BootStrapContext context)
ProtobufLengthDecoder(BufferAllocator allocator, OutOfMemoryHandler outOfMemoryHandler)

Uses of BufferAllocator in org.apache.drill.exec.rpc.control

Methods in org.apache.drill.exec.rpc.control with parameters of type BufferAllocator

Modifier and Type	Method and Description
ProtobufLengthDecoder	ControlClient.getDecoder(BufferAllocator allocator)
protected ProtobufLengthDecoder	ControlServer.getDecoder(BufferAllocator allocator, OutOfMemoryHandler outOfMemoryHandler)
void	ControlRpcMetrics.initialize(boolean useEncryptedCounter, BufferAllocator allocator) Should only be called when first access to getInstance is made.

Constructors in org.apache.drill.exec.rpc.control with parameters of type BufferAllocator

Constructor and Description
ControllerImpl(BootStrapContext context, BufferAllocator allocator, ControlMessageHandler handler)
ControlProtobufLengthDecoder(BufferAllocator allocator, OutOfMemoryHandler outOfMemoryHandler)

Uses of BufferAllocator in org.apache.drill.exec.rpc.data

Methods in org.apache.drill.exec.rpc.data that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	DataClientConnection.getAllocator()

Methods in org.apache.drill.exec.rpc.data with parameters of type BufferAllocator

Modifier and Type	Method and Description
ProtobufLengthDecoder	DataClient.getDecoder(BufferAllocator allocator)
protected ProtobufLengthDecoder	DataServer.getDecoder(BufferAllocator allocator, OutOfMemoryHandler outOfMemoryHandler)
void	DataRpcMetrics.initialize(boolean useEncryptedCounter, BufferAllocator allocator) Should only be called when first access to getInstance is made.
RawFragmentBatch	IncomingDataBatch.newRawFragmentBatch(BufferAllocator allocator) Create a new RawFragmentBatch based on this incoming data batch that is transferred into the provided allocator.

Constructors in org.apache.drill.exec.rpc.data with parameters of type BufferAllocator

Constructor and Description
Client(BufferAllocator allocator, OutOfMemoryHandler outOfMemoryHandler)
DataConnectionCreator(BootStrapContext context, BufferAllocator allocator, WorkEventBus workBus, WorkManager.WorkerBee bee)
Server(BufferAllocator allocator, OutOfMemoryHandler outOfMemoryHandler)

Uses of BufferAllocator in org.apache.drill.exec.rpc.user

Methods in org.apache.drill.exec.rpc.user that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	UserClient.UserToBitConnection.getAllocator()

Methods in org.apache.drill.exec.rpc.user with parameters of type BufferAllocator

Modifier and Type	Method and Description
ProtobufLengthDecoder	UserClient.getDecoder(BufferAllocator allocator)
protected ProtobufLengthDecoder	UserServer.getDecoder(BufferAllocator allocator, OutOfMemoryHandler outOfMemoryHandler)
void	UserRpcMetrics.initialize(boolean useEncryptedCounter, BufferAllocator allocator) Should only be called when first access to getInstance is made.

Constructors in org.apache.drill.exec.rpc.user with parameters of type BufferAllocator

Constructor and Description
UserClient(String clientName, DrillConfig config, Properties properties, boolean supportComplexTypes, BufferAllocator allocator, io.netty.channel.EventLoopGroup eventLoopGroup, Executor eventExecutor, CoordinationProtos.DrillbitEndpoint endpoint)
UserProtobufLengthDecoder(BufferAllocator allocator, OutOfMemoryHandler outOfMemoryHandler)
UserServer(BootStrapContext context, BufferAllocator allocator, io.netty.channel.EventLoopGroup eventLoopGroup, UserWorker worker)

Uses of BufferAllocator in org.apache.drill.exec.server

Methods in org.apache.drill.exec.server that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	BootStrapContext.getAllocator()
BufferAllocator	DrillbitContext.getAllocator()

Uses of BufferAllocator in org.apache.drill.exec.server.rest

Methods in org.apache.drill.exec.server.rest that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	WebSessionResources.getAllocator()

Uses of BufferAllocator in org.apache.drill.exec.ssl

Methods in org.apache.drill.exec.ssl with parameters of type BufferAllocator

Modifier and Type	Method and Description
SSLEngine	SSLConfigServer.createSSLEngine(BufferAllocator allocator, String peerHost, int peerPort)
SSLEngine	SSLConfig.createSSLEngine(BufferAllocator allocator, String peerHost, int peerPort)
SSLEngine	SSLConfigClient.createSSLEngine(BufferAllocator allocator, String peerHost, int peerPort)

Uses of BufferAllocator in org.apache.drill.exec.store

Constructors in org.apache.drill.exec.store with parameters of type BufferAllocator

Constructor and Description
TestOutputMutator(BufferAllocator allocator)

Uses of BufferAllocator in org.apache.drill.exec.store.easy.text.writer

Constructors in org.apache.drill.exec.store.easy.text.writer with parameters of type BufferAllocator

Constructor and Description
TextRecordWriter(BufferAllocator allocator, StorageStrategy storageStrategy, org.apache.hadoop.conf.Configuration fsConf)

Uses of BufferAllocator in org.apache.drill.exec.store.parquet

Constructors in org.apache.drill.exec.store.parquet with parameters of type BufferAllocator

Constructor and Description
ParquetDirectByteBufferAllocator(BufferAllocator allocator)

Uses of BufferAllocator in org.apache.drill.exec.store.parquet.columnreaders.batchsizing

Methods in org.apache.drill.exec.store.parquet.columnreaders.batchsizing with parameters of type BufferAllocator

Modifier and Type	Method and Description
static RecordBatchOverflow.Builder	RecordBatchOverflow.newBuilder(BufferAllocator allocator, RecordBatchStats.RecordBatchStatsContext batchStatsContext)

Uses of BufferAllocator in org.apache.drill.exec.util.filereader

Fields in org.apache.drill.exec.util.filereader declared as BufferAllocator

Modifier and Type	Field and Description
protected BufferAllocator	DirectBufInputStream.allocator

Constructors in org.apache.drill.exec.util.filereader with parameters of type BufferAllocator

Constructor and Description
BufferedDirectBufInputStream(InputStream in, BufferAllocator allocator, String id, long startOffset, long totalByteSize, boolean enforceTotalByteSize, boolean enableHints) Creates a BufferedDirectBufInputStream with the default (8 MiB) buffer size.
BufferedDirectBufInputStream(InputStream in, BufferAllocator allocator, String id, long startOffset, long totalByteSize, int bufSize, boolean enforceTotalByteSize, boolean enableHints) Creates a BufferedDirectBufInputStream with the specified buffer size.
DirectBufInputStream(InputStream in, BufferAllocator allocator, String id, long startOffset, long totalByteSize, boolean enforceTotalByteSize, boolean enableHints)

Uses of BufferAllocator in org.apache.drill.exec.util.record

Methods in org.apache.drill.exec.util.record with parameters of type BufferAllocator

Modifier and Type	Method and Description
static String	RecordBatchStats.printAllocatorStats(BufferAllocator allocator)

Uses of BufferAllocator in org.apache.drill.exec.vector

Fields in org.apache.drill.exec.vector declared as BufferAllocator

Modifier and Type	Field and Description
protected BufferAllocator	BaseValueVector.allocator

Methods in org.apache.drill.exec.vector that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	ValueVector.getAllocator()
BufferAllocator	BaseValueVector.getAllocator()
BufferAllocator	ZeroVector.getAllocator()

Methods in org.apache.drill.exec.vector with parameters of type BufferAllocator

Modifier and Type	Method and Description
TransferPair	UntypedNullVector.getTransferPair(BufferAllocator allocator)
TransferPair	ValueVector.getTransferPair(BufferAllocator allocator) Returns a transfer pair, creating a new target vector of the same type.
TransferPair	BitVector.getTransferPair(BufferAllocator allocator)
TransferPair	BaseValueVector.getTransferPair(BufferAllocator allocator)
TransferPair	ObjectVector.getTransferPair(BufferAllocator allocator)
TransferPair	ZeroVector.getTransferPair(BufferAllocator allocator)
TransferPair	UntypedNullVector.getTransferPair(String ref, BufferAllocator allocator)
TransferPair	ValueVector.getTransferPair(String ref, BufferAllocator allocator)
TransferPair	BitVector.getTransferPair(String ref, BufferAllocator allocator)
TransferPair	ObjectVector.getTransferPair(String ref, BufferAllocator allocator)
TransferPair	ZeroVector.getTransferPair(String ref, BufferAllocator allocator)
static org.apache.drill.exec.expr.holders.VarCharHolder	ValueHolderHelper.getVarCharHolder(BufferAllocator a, String s)

Constructors in org.apache.drill.exec.vector with parameters of type BufferAllocator

Constructor and Description
BaseDataValueVector(MaterializedField field, BufferAllocator allocator)
BaseValueVector(MaterializedField field, BufferAllocator allocator)
BitVector(MaterializedField field, BufferAllocator allocator)
ObjectVector(MaterializedField field, BufferAllocator allocator)
UntypedNullVector(MaterializedField field, BufferAllocator allocator)

Uses of BufferAllocator in org.apache.drill.exec.vector.complex

Fields in org.apache.drill.exec.vector.complex declared as BufferAllocator

Modifier and Type	Field and Description
protected BufferAllocator	AbstractContainerVector.allocator

Methods in org.apache.drill.exec.vector.complex that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	AbstractContainerVector.getAllocator()

Methods in org.apache.drill.exec.vector.complex with parameters of type BufferAllocator

Modifier and Type	Method and Description
TransferPair	RepeatedListVector.getTransferPair(BufferAllocator allocator)
TransferPair	RepeatedMapVector.getTransferPair(BufferAllocator allocator)
TransferPair	DictVector.getTransferPair(BufferAllocator allocator)
TransferPair	MapVector.getTransferPair(BufferAllocator allocator)
TransferPair	RepeatedListVector.getTransferPair(String ref, BufferAllocator allocator)
TransferPair	RepeatedListVector.DelegateRepeatedVector.getTransferPair(String ref, BufferAllocator allocator)
TransferPair	ListVector.getTransferPair(String ref, BufferAllocator allocator)
TransferPair	RepeatedMapVector.getTransferPair(String ref, BufferAllocator allocator)
TransferPair	DictVector.getTransferPair(String ref, BufferAllocator allocator)
TransferPair	MapVector.getTransferPair(String ref, BufferAllocator allocator)
TransferPair	RepeatedDictVector.getTransferPair(String ref, BufferAllocator allocator)
TransferPair	AbstractRepeatedMapVector.getTransferPairToSingleMap(String reference, BufferAllocator allocator)

Constructors in org.apache.drill.exec.vector.complex with parameters of type BufferAllocator

Constructor and Description
AbstractContainerVector(MaterializedField field, BufferAllocator allocator, CallBack callBack)
AbstractMapVector(MaterializedField field, BufferAllocator allocator, CallBack callBack)
AbstractRepeatedMapVector(MaterializedField field, BufferAllocator allocator, CallBack callBack)
BaseRepeatedValueVector(MaterializedField field, BufferAllocator allocator)
BaseRepeatedValueVector(MaterializedField field, BufferAllocator allocator, ValueVector vector)
DelegateRepeatedVector(MaterializedField field, BufferAllocator allocator)
DelegateRepeatedVector(String path, BufferAllocator allocator)
DictVector(MaterializedField field, BufferAllocator allocator, CallBack callBack)
DictVector(MaterializedField field, BufferAllocator allocator, CallBack callBack, TypeProtos.MajorType keyType, TypeProtos.MajorType valueType)
ListVector(MaterializedField field, BufferAllocator allocator, CallBack callBack)
MapTransferPair(MapVector from, String path, BufferAllocator allocator)
MapVector(MaterializedField field, BufferAllocator allocator, CallBack callBack)
MapVector(String path, BufferAllocator allocator, CallBack callBack)
RepeatedDictVector(MaterializedField field, BufferAllocator allocator, CallBack callback)
RepeatedDictVector(String path, BufferAllocator allocator)
RepeatedListVector(MaterializedField field, BufferAllocator allocator, CallBack callBack)
RepeatedListVector(MaterializedField field, BufferAllocator allocator, CallBack callBack, RepeatedListVector.DelegateRepeatedVector delegate)
RepeatedListVector(String path, BufferAllocator allocator, CallBack callBack)
RepeatedMapVector(MaterializedField field, BufferAllocator allocator, CallBack callBack)

Uses of BufferAllocator in org.apache.drill.exec.work.batch

Fields in org.apache.drill.exec.work.batch declared as BufferAllocator

Modifier and Type	Field and Description
protected BufferAllocator	AbstractDataCollector.ownerAllocator Allocator which owns incoming batches

Methods in org.apache.drill.exec.work.batch that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	DataCollector.getAllocator()
BufferAllocator	AbstractDataCollector.getAllocator()

Methods in org.apache.drill.exec.work.batch with parameters of type BufferAllocator

Modifier and Type	Method and Description
void	DataCollector.setAllocator(BufferAllocator allocator) Enables caller (e.g., receiver) to attach its buffer allocator to this Data Collector in order to claim ownership of incoming batches; by default, the fragment allocator owns these batches.
void	AbstractDataCollector.setAllocator(BufferAllocator allocator) Enables caller (e.g., receiver) to attach its buffer allocator to this Data Collector in order to claim ownership of incoming batches; by default, the fragment allocator owns these batches.

Uses of BufferAllocator in org.apache.drill.exec.work.filter

Methods in org.apache.drill.exec.work.filter with parameters of type BufferAllocator

Modifier and Type	Method and Description
RuntimeFilterWritable	RuntimeFilterWritable.duplicate(BufferAllocator bufferAllocator)
RuntimeFilterWritable	RuntimeFilterWritable.newRuntimeFilterWritable(BufferAllocator bufferAllocator)

Constructors in org.apache.drill.exec.work.filter with parameters of type BufferAllocator

Constructor and Description
BloomFilter(int numBytes, BufferAllocator bufferAllocator)
BloomFilter(int ndv, double fpp, BufferAllocator bufferAllocator)

Uses of BufferAllocator in org.apache.drill.test

Fields in org.apache.drill.test declared as BufferAllocator

Modifier and Type	Field and Description
protected static BufferAllocator	BaseTestQuery.allocator
protected BufferAllocator	BaseFixture.allocator

Methods in org.apache.drill.test that return BufferAllocator

Modifier and Type	Method and Description
BufferAllocator	ClientFixture.allocator()
BufferAllocator	BaseTestQuery.ClassicTestServices.allocator()
BufferAllocator	ClusterFixture.FixtureTestServices.allocator()
BufferAllocator	DrillTestWrapper.TestServices.allocator()
BufferAllocator	BaseFixture.allocator()
BufferAllocator	OperatorFixture.MockFragmentContext.getAllocator()
protected static BufferAllocator	BaseTestQuery.getAllocator()
BufferAllocator	OperatorFixture.MockFragmentContext.getNewChildAllocator(String operatorName, int operatorId, long initialReservation, long maximumReservation)
BufferAllocator	PhysicalOpUnitTestBase.MockExecutorFragmentContext.getRootAllocator()

Methods in org.apache.drill.test with parameters of type BufferAllocator

Modifier and Type	Method and Description
static QueryRowSetReader	QueryRowSetReader.build(BufferAllocator allocator, BufferingQueryEventListener listener)
static void	BaseFixture.dirtyMemory(BufferAllocator allocator, int blockCount)

Constructors in org.apache.drill.test with parameters of type BufferAllocator

Constructor and Description
MockFragmentContext(DrillConfig config, OptionManager options, BufferAllocator allocator, ExecutorService scanExecutorService, ExecutorService scanDecodeExecutorService)
MockOperatorContext(FragmentContext fragContext, BufferAllocator allocator, PhysicalOperator config)
QueryBatchIterator(BufferAllocator allocator, BufferingQueryEventListener listener)
QueryResultSet(BufferingQueryEventListener listener, BufferAllocator allocator)
QueryRowSetIterator(BufferAllocator allocator, BufferingQueryEventListener listener)

Uses of BufferAllocator in org.apache.parquet.hadoop

Constructors in org.apache.parquet.hadoop with parameters of type BufferAllocator

Constructor and Description
ColumnChunkIncReadStore(long rowCount, org.apache.parquet.hadoop.CodecFactory codecFactory, BufferAllocator allocator, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path)