Uses of Interface
org.apache.drill.exec.record.RecordBatch

Packages that use RecordBatch

Package	Description
org.apache.drill.exec.disk	Interface for Drill's interaction with the local disk to persist data temporarily during an operation.
org.apache.drill.exec.expr.fn.impl
org.apache.drill.exec.expr.fn.interpreter
org.apache.drill.exec.ops
org.apache.drill.exec.physical.base
org.apache.drill.exec.physical.impl
org.apache.drill.exec.physical.impl.aggregate
org.apache.drill.exec.physical.impl.broadcastsender
org.apache.drill.exec.physical.impl.common
org.apache.drill.exec.physical.impl.filter
org.apache.drill.exec.physical.impl.flatten
org.apache.drill.exec.physical.impl.join
org.apache.drill.exec.physical.impl.limit
org.apache.drill.exec.physical.impl.materialize
org.apache.drill.exec.physical.impl.mergereceiver
org.apache.drill.exec.physical.impl.metadata
org.apache.drill.exec.physical.impl.orderedpartitioner
org.apache.drill.exec.physical.impl.partitionsender
org.apache.drill.exec.physical.impl.producer
org.apache.drill.exec.physical.impl.project
org.apache.drill.exec.physical.impl.protocol	Defines a revised implementation of the Drill RecordBatch protocol.
org.apache.drill.exec.physical.impl.rangepartitioner
org.apache.drill.exec.physical.impl.setop
org.apache.drill.exec.physical.impl.sort
org.apache.drill.exec.physical.impl.statistics
org.apache.drill.exec.physical.impl.svremover
org.apache.drill.exec.physical.impl.TopN
org.apache.drill.exec.physical.impl.trace
org.apache.drill.exec.physical.impl.union
org.apache.drill.exec.physical.impl.unnest
org.apache.drill.exec.physical.impl.unorderedreceiver
org.apache.drill.exec.physical.impl.unpivot
org.apache.drill.exec.physical.impl.validate
org.apache.drill.exec.physical.impl.values
org.apache.drill.exec.physical.impl.window
org.apache.drill.exec.physical.impl.xsort
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.store.delta.read
org.apache.drill.exec.store.dfs.easy
org.apache.drill.exec.store.direct
org.apache.drill.exec.store.drill.plugin	Drill storage plugin.
org.apache.drill.exec.store.druid
org.apache.drill.exec.store.enumerable
org.apache.drill.exec.store.googlesheets
org.apache.drill.exec.store.hbase
org.apache.drill.exec.store.hive
org.apache.drill.exec.store.http
org.apache.drill.exec.store.iceberg.read
org.apache.drill.exec.store.ischema
org.apache.drill.exec.store.jdbc
org.apache.drill.exec.store.kafka	Kafka storage plugin.
org.apache.drill.exec.store.kudu
org.apache.drill.exec.store.mock	Defines a mock data source which generates dummy test data for use in testing.
org.apache.drill.exec.store.mongo	MongoDB storage plugin.
org.apache.drill.exec.store.openTSDB
org.apache.drill.exec.store.parquet
org.apache.drill.exec.store.phoenix
org.apache.drill.exec.store.splunk
org.apache.drill.exec.store.sys
org.apache.drill.exec.util.record
org.apache.drill.exec.vector

Uses of RecordBatch in org.apache.drill.exec.disk

Methods in org.apache.drill.exec.disk with parameters of type RecordBatch

Modifier and Type	Method	Description
void	Spool.read(RecordBatch batch)
void	Spool.write(RecordBatch batch)

Uses of RecordBatch in org.apache.drill.exec.expr.fn.impl

Methods in org.apache.drill.exec.expr.fn.impl with parameters of type RecordBatch

Modifier and Type	Method	Description
void	ValueVectorHashHelper.Hash64.doSetup(RecordBatch incoming)
abstract void	ValueVectorHashHelper.Hash64Template.doSetup(RecordBatch incoming)

Constructors in org.apache.drill.exec.expr.fn.impl with parameters of type RecordBatch

Modifier	Constructor	Description
	ValueVectorHashHelper(RecordBatch recordBatch, FragmentContext context)

Uses of RecordBatch in org.apache.drill.exec.expr.fn.interpreter

Methods in org.apache.drill.exec.expr.fn.interpreter with parameters of type RecordBatch

Modifier and Type	Method	Description
static void	InterpreterEvaluator.evaluate(RecordBatch incoming, ValueVector outVV, LogicalExpression expr)

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

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

Modifier and Type	Method	Description
void	FragmentContext.requestMemory(RecordBatch requestor)	An operator is experiencing memory pressure.
void	FragmentContextImpl.requestMemory(RecordBatch requestor)

Uses of RecordBatch in org.apache.drill.exec.physical.base

Methods in org.apache.drill.exec.physical.base that return RecordBatch

Modifier and Type	Method	Description
RecordBatch	LateralContract.getIncoming()	Get reference to left side incoming of LateralJoinBatch.

Method parameters in org.apache.drill.exec.physical.base with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	SchemalessBatchCreator.getBatch(ExecutorFragmentContext context, SchemalessScan subScan, List<RecordBatch> children)

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

Classes in org.apache.drill.exec.physical.impl that implement RecordBatch

Modifier and Type	Class	Description
class	InsertWriterRecordBatch
class	ScanBatch	Record batch used for a particular scan.
class	StatisticsWriterRecordBatch
class	WriterRecordBatch	Write the RecordBatch to the given RecordWriter.

Methods in org.apache.drill.exec.physical.impl that return RecordBatch

Modifier and Type	Method	Description
protected RecordBatch	ScreenCreator.ScreenRoot.getIncoming()
RecordBatch	ImplCreator.getRecordBatch(PhysicalOperator op, ExecutorFragmentContext context)	Create a RecordBatch and its children for given PhysicalOperator

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

Modifier and Type	Method	Description
final RecordBatch.IterOutcome	BaseRootExec.next(RecordBatch b)

Method parameters in org.apache.drill.exec.physical.impl with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	BatchCreator.getBatch(ExecutorFragmentContext context, T config, List<RecordBatch> children)
MergingRecordBatch	MergingReceiverCreator.getBatch(ExecutorFragmentContext context, MergingReceiverPOP receiver, List<RecordBatch> children)
RootExec	RootCreator.getRoot(ExecutorFragmentContext context, T config, List<RecordBatch> children)
RootExec	ScreenCreator.getRoot(ExecutorFragmentContext context, Screen config, List<RecordBatch> children)
RootExec	SingleSenderCreator.getRoot(ExecutorFragmentContext context, SingleSender config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	InsertWriterRecordBatch(Writer writer, RecordBatch incoming, FragmentContext context, RecordWriter recordWriter)
	ScreenRoot(RootFragmentContext context, RecordBatch incoming, Screen config)
	SingleSenderRootExec(RootFragmentContext context, RecordBatch batch, SingleSender config)
	StatisticsWriterRecordBatch(Writer writer, RecordBatch incoming, FragmentContext context, StatisticsRecordWriter recordWriter)
	WriterRecordBatch(Writer writer, RecordBatch incoming, FragmentContext context, RecordWriter recordWriter)

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

Classes in org.apache.drill.exec.physical.impl.aggregate that implement RecordBatch

Modifier and Type	Class	Description
class	HashAggBatch
class	SpilledRecordBatch	Replaces "incoming" - instead scanning a spilled partition file
class	StreamingAggBatch

Fields in org.apache.drill.exec.physical.impl.aggregate declared as RecordBatch

Modifier and Type	Field	Description
protected RecordBatch	HashAggBatch.incoming
protected final RecordBatch	StreamingAggBatch.incoming

Methods in org.apache.drill.exec.physical.impl.aggregate that return RecordBatch

Modifier and Type	Method	Description
RecordBatch	HashAggregator.getNewIncoming()
RecordBatch	HashAggTemplate.getNewIncoming()	get new incoming: (when reading spilled files like an "incoming")

Methods in org.apache.drill.exec.physical.impl.aggregate with parameters of type RecordBatch

Modifier and Type	Method	Description
abstract void	HashAggTemplate.doSetup(RecordBatch incoming)
void	HashAggregator.setup(HashAggregate hashAggrConfig, HashTableConfig htConfig, FragmentContext context, OperatorContext oContext, RecordBatch incoming, HashAggBatch outgoing, LogicalExpression[] valueExprs, List<TypedFieldId> valueFieldIds, ClassGenerator<?> cg, TypedFieldId[] keyFieldIds, VectorContainer outContainer, int extraRowBytes)
void	HashAggTemplate.setup(HashAggregate hashAggrConfig, HashTableConfig htConfig, FragmentContext context, OperatorContext oContext, RecordBatch incoming, HashAggBatch outgoing, LogicalExpression[] valueExprs, List<TypedFieldId> valueFieldIds, ClassGenerator<?> cg, TypedFieldId[] groupByOutFieldIds, VectorContainer outContainer, int extraRowBytes)
void	StreamingAggregator.setup(OperatorContext context, RecordBatch incoming, StreamingAggBatch outgoing, int outputRowCount)
void	StreamingAggTemplate.setup(OperatorContext context, RecordBatch incoming, StreamingAggBatch outgoing, int outputRowCount)
void	HashAggTemplate.BatchHolder.setupInterior(RecordBatch incoming, RecordBatch outgoing, VectorContainer aggrValuesContainer)
abstract void	StreamingAggTemplate.setupInterior(RecordBatch incoming, RecordBatch outgoing)

Method parameters in org.apache.drill.exec.physical.impl.aggregate with type arguments of type RecordBatch

Modifier and Type	Method	Description
HashAggBatch	HashAggBatchCreator.getBatch(ExecutorFragmentContext context, HashAggregate config, List<RecordBatch> children)
StreamingAggBatch	StreamingAggBatchCreator.getBatch(ExecutorFragmentContext context, StreamingAggregate config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	HashAggBatch(HashAggregate popConfig, RecordBatch incoming, FragmentContext context)
	InternalBatch(RecordBatch incoming, OperatorContext oContext)
	InternalBatch(RecordBatch incoming, VectorWrapper<?>[] ignoreWrappers, OperatorContext oContext)
	StreamingAggBatch(StreamingAggregate popConfig, RecordBatch incoming, FragmentContext context)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.broadcastsender

Method parameters in org.apache.drill.exec.physical.impl.broadcastsender with type arguments of type RecordBatch

Modifier and Type	Method	Description
RootExec	BroadcastSenderCreator.getRoot(ExecutorFragmentContext context, BroadcastSender config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	BroadcastSenderRootExec(RootFragmentContext context, RecordBatch incoming, BroadcastSender config)

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

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

Modifier and Type	Method	Description
protected abstract void	HashTableTemplate.doSetup(VectorContainer incomingBuild, RecordBatch incomingProbe)
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.
void	HashTableTemplate.setup(HashTableConfig htConfig, BufferAllocator allocator, VectorContainer incomingBuild, RecordBatch incomingProbe, RecordBatch outgoing, VectorContainer htContainerOrig, FragmentContext context, ClassGenerator<?> cg)
protected void	HashTableTemplate.BatchHolder.setupInterior(VectorContainer incomingBuild, RecordBatch incomingProbe, RecordBatch outgoing, VectorContainer htContainer)
void	ChainedHashTable.updateIncoming(RecordBatch incomingBuild, RecordBatch incomingProbe)
void	HashTable.updateIncoming(VectorContainer newIncoming, RecordBatch newIncomingProbe)	Changes the incoming probe and build side batches, and then updates all the value vector references in the HashTableTemplate.BatchHolders.
void	HashTableTemplate.updateIncoming(VectorContainer newIncoming, RecordBatch newIncomingProbe)

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

Modifier	Constructor	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 RecordBatch in org.apache.drill.exec.physical.impl.filter

Classes in org.apache.drill.exec.physical.impl.filter that implement RecordBatch

Modifier and Type	Class	Description
class	FilterRecordBatch
class	RuntimeFilterRecordBatch	A RuntimeFilterRecordBatch steps over the ScanBatch.

Methods in org.apache.drill.exec.physical.impl.filter with parameters of type RecordBatch

Modifier and Type	Method	Description
void	FilterSignature.doSetup(FragmentContextImpl context, RecordBatch incoming, RecordBatch outgoing)
abstract void	FilterTemplate2.doSetup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing)
abstract void	FilterTemplate4.doSetup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing)
void	Filterer.setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, TransferPair[] transfers)
void	FilterTemplate2.setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, TransferPair[] transfers)
void	FilterTemplate4.setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, TransferPair[] transfers)

Method parameters in org.apache.drill.exec.physical.impl.filter with type arguments of type RecordBatch

Modifier and Type	Method	Description
FilterRecordBatch	FilterBatchCreator.getBatch(ExecutorFragmentContext context, Filter config, List<RecordBatch> children)
CloseableRecordBatch	RuntimeFilterBatchCreator.getBatch(ExecutorFragmentContext context, RuntimeFilterPOP config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	FilterRecordBatch(Filter pop, RecordBatch incoming, FragmentContext context)
	RuntimeFilterRecordBatch(RuntimeFilterPOP pop, RecordBatch incoming, FragmentContext context)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.flatten

Classes in org.apache.drill.exec.physical.impl.flatten that implement RecordBatch

Modifier and Type	Class	Description
class	FlattenRecordBatch

Methods in org.apache.drill.exec.physical.impl.flatten with parameters of type RecordBatch

Modifier and Type	Method	Description
abstract void	FlattenTemplate.doSetup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing)
void	Flattener.setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, List<TransferPair> transfers)
final void	FlattenTemplate.setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, List<TransferPair> transfers)

Method parameters in org.apache.drill.exec.physical.impl.flatten with type arguments of type RecordBatch

Modifier and Type	Method	Description
FlattenRecordBatch	FlattenBatchCreator.getBatch(ExecutorFragmentContext context, FlattenPOP config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	FlattenRecordBatch(FlattenPOP pop, RecordBatch incoming, FragmentContext context)

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

Classes in org.apache.drill.exec.physical.impl.join that implement RecordBatch

Modifier and Type	Class	Description
class	AbstractHashBinaryRecordBatch<T extends PhysicalOperator>	Base class for the runtime execution implementation of the Hash-Join and Hash-SetOp operator
class	HashJoinBatch	Implements the runtime execution for the Hash-Join operator supporting INNER, LEFT OUTER, RIGHT OUTER, and FULL OUTER joins
class	LateralJoinBatch	RecordBatch implementation for the lateral join operator.
class	MergeJoinBatch	A join operator that merges two sorted streams using a record iterator.
class	NestedLoopJoinBatch
class	RowKeyJoinBatch

Fields in org.apache.drill.exec.physical.impl.join declared as RecordBatch

Modifier and Type	Field	Description
protected RecordBatch	AbstractHashBinaryRecordBatch.buildBatch
protected RecordBatch	AbstractHashBinaryRecordBatch.probeBatch
protected RecordBatch	ProbeTemplate.probeBatch

Methods in org.apache.drill.exec.physical.impl.join that return RecordBatch

Modifier and Type	Method	Description
RecordBatch	LateralJoinBatch.getIncoming()	Returns the left side incoming for the Lateral Join.

Methods in org.apache.drill.exec.physical.impl.join with parameters of type RecordBatch

Modifier and Type	Method	Description
BatchSizePredictor	BatchSizePredictor.Factory.create(RecordBatch batch, double fragmentationFactor, double safetyFactor)	Creates a predictor with a batch whose data needs to be used to predict other batch sizes.
BatchSizePredictor	BatchSizePredictorImpl.Factory.create(RecordBatch batch, double fragmentationFactor, double safetyFactor)
void	NestedLoopJoin.doSetup(FragmentContext context, VectorContainer rightContainer, RecordBatch leftBatch, RecordBatch outgoing)
abstract void	NestedLoopJoinTemplate.doSetup(FragmentContext context, VectorContainer rightContainer, RecordBatch leftBatch, RecordBatch outgoing)
static long	BatchSizePredictorImpl.getBatchSizeEstimate(RecordBatch recordBatch)
void	HashJoinMechanicalMemoryCalculator.MechanicalBuildSidePartitioning.initialize(boolean autoTune, boolean reserveHash, RecordBatch buildSideBatch, RecordBatch probeSideBatch, Set<String> joinColumns, boolean probeEmpty, long memoryAvailable, int initialPartitions, int recordsPerPartitionBatchBuild, int recordsPerPartitionBatchProbe, int maxBatchNumRecordsBuild, int maxBatchNumRecordsProbe, int outputBatchSize, double loadFactor)
void	HashJoinMemoryCalculator.BuildSidePartitioning.initialize(boolean firstCycle, boolean reserveHash, RecordBatch buildSideBatch, RecordBatch probeSideBatch, Set<String> joinColumns, boolean probeEmpty, long memoryAvailable, int initialPartitions, int recordsPerPartitionBatchBuild, int recordsPerPartitionBatchProbe, int maxBatchNumRecordsBuild, int maxBatchNumRecordsProbe, int outputBatchSize, double loadFactor)
void	HashJoinMemoryCalculatorImpl.BuildSidePartitioningImpl.initialize(boolean firstCycle, boolean reserveHash, RecordBatch buildBatch, RecordBatch probeBatch, Set<String> joinColumns, boolean probeEmpty, long memoryAvailable, int initialPartitions, int recordsPerPartitionBatchBuild, int recordsPerPartitionBatchProbe, int maxBatchNumRecordsBuild, int maxBatchNumRecordsProbe, int outputBatchSize, double loadFactor)
void	HashJoinMemoryCalculatorImpl.NoopBuildSidePartitioningImpl.initialize(boolean firstCycle, boolean reserveHash, RecordBatch buildSideBatch, RecordBatch probeSideBatch, Set<String> joinColumns, boolean probeEmpty, long memoryAvailable, int initialPartitions, int recordsPerPartitionBatchBuild, int recordsPerPartitionBatchProbe, int maxBatchNumRecordsBuild, int maxBatchNumRecordsProbe, int outputBatchSize, double loadFactor)
void	HashJoinProbeTemplate.setup(RecordBatch probeBatch, HashJoinBatch outgoing, org.apache.calcite.rel.core.JoinRelType joinRelType, boolean semiJoin, RecordBatch.IterOutcome leftStartState, HashPartition[] partitions, int cycleNum, VectorContainer container, AbstractHashBinaryRecordBatch.SpilledPartition[] spilledInners, boolean buildSideIsEmpty, int numPartitions, int rightHVColPosition)	Setup the Hash Join Probe object
default void	Probe.setup(RecordBatch probeBatch, HashJoinBatch outgoing, org.apache.calcite.rel.core.JoinRelType joinRelType, boolean semiJoin, RecordBatch.IterOutcome leftStartState, HashPartition[] partitions, int cycleNum, VectorContainer container, AbstractHashBinaryRecordBatch.SpilledPartition[] spilledInners, boolean buildSideIsEmpty, int numPartitions, int rightHVColPosition)
default void	Probe.setup(RecordBatch probeBatch, HashSetOpRecordBatch outgoing, org.apache.calcite.sql.SqlKind opType, boolean isAll, RecordBatch.IterOutcome leftStartState, HashPartition[] partitions, int cycleNum, VectorContainer container, AbstractHashBinaryRecordBatch.SpilledPartition[] spilledInners, boolean buildSideIsEmpty, int numPartitions)
protected void	ProbeTemplate.setup(RecordBatch probeBatch, RecordBatch.IterOutcome leftStartState, HashPartition[] partitions, int cycleNum, VectorContainer container, AbstractHashBinaryRecordBatch.SpilledPartition[] spilledInners, boolean buildSideIsEmpty, int numPartitions)
void	NestedLoopJoin.setupNestedLoopJoin(FragmentContext context, RecordBatch left, ExpandableHyperContainer rightContainer, LinkedList<Integer> rightCounts, NestedLoopJoinBatch outgoing)
void	NestedLoopJoinTemplate.setupNestedLoopJoin(FragmentContext context, RecordBatch left, ExpandableHyperContainer rightContainer, LinkedList<Integer> rightCounts, NestedLoopJoinBatch outgoing)	Method initializes necessary state and invokes the doSetup() to set the input and output value vector references.

Method parameters in org.apache.drill.exec.physical.impl.join with type arguments of type RecordBatch

Modifier and Type	Method	Description
HashJoinBatch	HashJoinBatchCreator.getBatch(ExecutorFragmentContext context, HashJoinPOP config, List<RecordBatch> children)
LateralJoinBatch	LateralJoinBatchCreator.getBatch(ExecutorFragmentContext context, LateralJoinPOP config, List<RecordBatch> children)
MergeJoinBatch	MergeJoinCreator.getBatch(ExecutorFragmentContext context, MergeJoinPOP config, List<RecordBatch> children)
NestedLoopJoinBatch	NestedLoopJoinBatchCreator.getBatch(ExecutorFragmentContext context, NestedLoopJoinPOP config, List<RecordBatch> children)
RowKeyJoinBatch	RowKeyJoinBatchCreator.getBatch(ExecutorFragmentContext context, RowKeyJoinPOP config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	AbstractHashBinaryRecordBatch(T popConfig, FragmentContext context, RecordBatch left, RecordBatch right)	The constructor
	BatchSizePredictorImpl(RecordBatch batch, double fragmentationFactor, double safetyFactor)
	HashJoinBatch(HashJoinPOP popConfig, FragmentContext context, RecordBatch left, RecordBatch right)	The constructor
	LateralJoinBatch(LateralJoinPOP popConfig, FragmentContext context, RecordBatch left, RecordBatch right)
protected	MergeJoinBatch(MergeJoinPOP popConfig, FragmentContext context, RecordBatch left, RecordBatch right)
protected	NestedLoopJoinBatch(NestedLoopJoinPOP popConfig, FragmentContext context, RecordBatch left, RecordBatch right)
	RowKeyJoinBatch(RowKeyJoinPOP config, FragmentContext context, RecordBatch left, RecordBatch right)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.limit

Classes in org.apache.drill.exec.physical.impl.limit that implement RecordBatch

Modifier and Type	Class	Description
class	LimitRecordBatch
class	PartitionLimitRecordBatch	Helps to perform limit in a partition within a record batch.

Method parameters in org.apache.drill.exec.physical.impl.limit with type arguments of type RecordBatch

Modifier and Type	Method	Description
LimitRecordBatch	LimitBatchCreator.getBatch(ExecutorFragmentContext context, Limit config, List<RecordBatch> children)
PartitionLimitRecordBatch	PartitionLimitBatchCreator.getBatch(ExecutorFragmentContext context, PartitionLimit config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	LimitRecordBatch(Limit popConfig, FragmentContext context, RecordBatch incoming)
	PartitionLimitRecordBatch(PartitionLimit popConfig, FragmentContext context, RecordBatch incoming)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.materialize

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

Modifier	Constructor	Description
	VectorRecordMaterializer(FragmentContext context, OperatorContext oContext, RecordBatch batch)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.mergereceiver

Classes in org.apache.drill.exec.physical.impl.mergereceiver that implement RecordBatch

Modifier and Type	Class	Description
class	MergingRecordBatch	Merges pre-sorted record batches from remote senders.

Uses of RecordBatch in org.apache.drill.exec.physical.impl.metadata

Classes in org.apache.drill.exec.physical.impl.metadata that implement RecordBatch

Modifier and Type	Class	Description
class	MetadataControllerBatch	Terminal operator for producing ANALYZE statement.
class	MetadataHandlerBatch	Responsible for handling metadata returned by incoming aggregate operators and fetching required metadata form the Metastore.
class	MetadataHashAggBatch
class	MetadataStreamAggBatch	Operator which adds aggregate calls for all incoming columns to calculate required metadata and produces aggregations.

Method parameters in org.apache.drill.exec.physical.impl.metadata with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	MetadataControllerBatchCreator.getBatch(ExecutorFragmentContext context, MetadataControllerPOP config, List<RecordBatch> children)
CloseableRecordBatch	MetadataHandlerBatchCreator.getBatch(ExecutorFragmentContext context, MetadataHandlerPOP config, List<RecordBatch> children)
CloseableRecordBatch	MetadataHashAggBatchCreator.getBatch(ExecutorFragmentContext context, MetadataHashAggPOP config, List<RecordBatch> children)
CloseableRecordBatch	MetadataStreamAggBatchCreator.getBatch(ExecutorFragmentContext context, MetadataStreamAggPOP config, List<RecordBatch> children)

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

Modifier	Constructor	Description
protected	MetadataControllerBatch(MetadataControllerPOP popConfig, FragmentContext context, RecordBatch left, RecordBatch right)
protected	MetadataHandlerBatch(MetadataHandlerPOP popConfig, FragmentContext context, RecordBatch incoming)
	MetadataHashAggBatch(MetadataHashAggPOP popConfig, RecordBatch incoming, FragmentContext context)
	MetadataStreamAggBatch(MetadataStreamAggPOP popConfig, RecordBatch incoming, FragmentContext context)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.orderedpartitioner

Classes in org.apache.drill.exec.physical.impl.orderedpartitioner that implement RecordBatch

Modifier and Type	Class	Description
class	OrderedPartitionRecordBatch	Generates an ordered partition, rather than a random hash partition.

Fields in org.apache.drill.exec.physical.impl.orderedpartitioner declared as RecordBatch

Modifier and Type	Field	Description
protected final RecordBatch	OrderedPartitionRecordBatch.incoming

Methods in org.apache.drill.exec.physical.impl.orderedpartitioner with parameters of type RecordBatch

Modifier and Type	Method	Description
abstract void	OrderedPartitionProjectorTemplate.doSetup(FragmentContext context, VectorAccessible incoming, RecordBatch outgoing, VectorContainer partitionVectors)
abstract void	SampleSortTemplate.doSetup(FragmentContext context, VectorContainer incoming, RecordBatch outgoing)
void	OrderedPartitionProjector.setup(FragmentContext context, VectorAccessible incoming, RecordBatch outgoing, List<TransferPair> transfers, VectorContainer partitionVectors, int partitions, SchemaPath outputField)
final void	OrderedPartitionProjectorTemplate.setup(FragmentContext context, VectorAccessible incoming, RecordBatch outgoing, List<TransferPair> transfers, VectorContainer partitionVectors, int partitions, SchemaPath outputField)
void	SampleSorter.setup(FragmentContext context, RecordBatch hyperBatch)

Method parameters in org.apache.drill.exec.physical.impl.orderedpartitioner with type arguments of type RecordBatch

Modifier and Type	Method	Description
RootExec	OrderedPartitionSenderCreator.getRoot(ExecutorFragmentContext context, OrderedPartitionSender config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	OrderedPartitionRecordBatch(OrderedPartitionSender pop, RecordBatch incoming, FragmentContext context)

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

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

Modifier and Type	Method	Description
abstract void	PartitionerTemplate.doSetup(FragmentContext context, RecordBatch incoming, PartitionerTemplate.OutgoingRecordBatch[] outgoing)
protected void	PartitionerTemplate.OutgoingRecordBatch.doSetup(RecordBatch incoming, VectorAccessible outgoing)
void	Partitioner.partitionBatch(RecordBatch incoming)
void	PartitionerDecorator.partitionBatch(RecordBatch incoming)	partitionBatch - decorator method to call real Partitioner(s) to process incoming batch uses either threading or not threading approach based on number Partitioners
void	PartitionerTemplate.partitionBatch(RecordBatch incoming)
void	Partitioner.setup(ExchangeFragmentContext context, RecordBatch incoming, HashPartitionSender popConfig, OperatorStats stats, OperatorContext oContext, ClassGenerator<?> cg, int start, int count)
final void	PartitionerTemplate.setup(ExchangeFragmentContext context, RecordBatch incoming, HashPartitionSender popConfig, OperatorStats stats, OperatorContext oContext, ClassGenerator<?> cg, int start, int end)

Method parameters in org.apache.drill.exec.physical.impl.partitionsender with type arguments of type RecordBatch

Modifier and Type	Method	Description
RootExec	PartitionSenderCreator.getRoot(ExecutorFragmentContext context, HashPartitionSender config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	PartitionSenderRootExec(RootFragmentContext context, RecordBatch incoming, HashPartitionSender operator)
	PartitionSenderRootExec(RootFragmentContext context, RecordBatch incoming, HashPartitionSender operator, boolean closeIncoming)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.producer

Classes in org.apache.drill.exec.physical.impl.producer that implement RecordBatch

Modifier and Type	Class	Description
class	ProducerConsumerBatch

Method parameters in org.apache.drill.exec.physical.impl.producer with type arguments of type RecordBatch

Modifier and Type	Method	Description
ProducerConsumerBatch	ProducerConsumerBatchCreator.getBatch(ExecutorFragmentContext context, ProducerConsumer config, List<RecordBatch> children)

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

Modifier	Constructor	Description
protected	ProducerConsumerBatch(ProducerConsumer popConfig, FragmentContext context, RecordBatch incoming)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.project

Classes in org.apache.drill.exec.physical.impl.project that implement RecordBatch

Modifier and Type	Class	Description
class	ProjectRecordBatch

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

Modifier and Type	Method	Description
RecordBatch	ProjectMemoryManager.incomingBatch()

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

Modifier and Type	Method	Description
abstract void	ProjectorTemplate.doSetup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing)
void	ProjectMemoryManager.init(RecordBatch incomingBatch, ProjectRecordBatch outgoingBatch)
int	Projector.projectRecords(RecordBatch incomingBatch, int startIndex, int recordCount, int firstOutputIndex)
final int	ProjectorTemplate.projectRecords(RecordBatch incomingRecordBatch, int startIndex, int recordCount, int firstOutputIndex)
void	Projector.setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, List<TransferPair> transfers)
final void	ProjectorTemplate.setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, List<TransferPair> transfers)

Method parameters in org.apache.drill.exec.physical.impl.project with type arguments of type RecordBatch

Modifier and Type	Method	Description
ProjectRecordBatch	ComplexToJsonBatchCreator.getBatch(ExecutorFragmentContext context, ComplexToJson flatten, List<RecordBatch> children)
ProjectRecordBatch	ProjectBatchCreator.getBatch(ExecutorFragmentContext context, Project config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	ProjectBatchBuilder(ProjectRecordBatch projectBatch, VectorContainer container, SchemaChangeCallBack callBack, RecordBatch incomingBatch)
	ProjectRecordBatch(Project pop, RecordBatch incoming, FragmentContext context)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.protocol

Classes in org.apache.drill.exec.physical.impl.protocol that implement RecordBatch

Modifier and Type	Class	Description
class	OperatorRecordBatch	Modular implementation of the standard Drill record batch iterator protocol.

Methods in org.apache.drill.exec.physical.impl.protocol with parameters of type RecordBatch

Modifier and Type	Method	Description
void	IndirectContainerAccessor.addBatch(RecordBatch batch)	Add a record batch, performing schema checks and picking out a selection vector, if provided.

Uses of RecordBatch in org.apache.drill.exec.physical.impl.rangepartitioner

Classes in org.apache.drill.exec.physical.impl.rangepartitioner that implement RecordBatch

Modifier and Type	Class	Description
class	RangePartitionRecordBatch	Provides the ability to divide up the input rows into a fixed number of separate ranges or 'buckets' based on the values of a set of columns (the range partitioning columns).

Method parameters in org.apache.drill.exec.physical.impl.rangepartitioner with type arguments of type RecordBatch

Modifier and Type	Method	Description
RootExec	RangePartitionSenderCreator.getRoot(ExecutorFragmentContext context, RangePartitionSender config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	RangePartitionRecordBatch(RangePartitionSender popConfig, RecordBatch incoming, FragmentContext context)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.setop

Classes in org.apache.drill.exec.physical.impl.setop that implement RecordBatch

Modifier and Type	Class	Description
class	HashSetOpRecordBatch	Implements the runtime execution for the Hash-SetOp operator supporting EXCEPT, EXCEPT ALL, INTERSECT, and INTERSECT ALL

Methods in org.apache.drill.exec.physical.impl.setop with parameters of type RecordBatch

Modifier and Type	Method	Description
void	HashSetOpProbeTemplate.setup(RecordBatch probeBatch, HashSetOpRecordBatch outgoing, org.apache.calcite.sql.SqlKind opType, boolean isAll, RecordBatch.IterOutcome leftStartState, HashPartition[] partitions, int cycleNum, VectorContainer container, AbstractHashBinaryRecordBatch.SpilledPartition[] spilledInners, boolean buildSideIsEmpty, int numPartitions)	Setup the Hash Set Op Probe object

Method parameters in org.apache.drill.exec.physical.impl.setop with type arguments of type RecordBatch

Modifier and Type	Method	Description
HashSetOpRecordBatch	SetOpBatchCreator.getBatch(ExecutorFragmentContext context, SetOp config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	HashSetOpRecordBatch(SetOp popConfig, FragmentContext context, RecordBatch left, RecordBatch right)	The constructor

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

Classes in org.apache.drill.exec.physical.impl.sort that implement RecordBatch

Modifier and Type	Class	Description
class	SortBatch

Methods in org.apache.drill.exec.physical.impl.sort with parameters of type RecordBatch

Modifier and Type	Method	Description
abstract void	SortTemplate.doSetup(FragmentContext context, VectorContainer incoming, RecordBatch outgoing)

Method parameters in org.apache.drill.exec.physical.impl.sort with type arguments of type RecordBatch

Modifier and Type	Method	Description
SortBatch	SortBatchCreator.getBatch(ExecutorFragmentContext context, Sort config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	SortBatch(Sort popConfig, FragmentContext context, RecordBatch incoming)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.statistics

Classes in org.apache.drill.exec.physical.impl.statistics that implement RecordBatch

Modifier and Type	Class	Description
class	StatisticsAggBatch
class	StatisticsMergeBatch	Example input and output: Schema of incoming batch:

Method parameters in org.apache.drill.exec.physical.impl.statistics with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	StatisticsAggBatchCreator.getBatch(ExecutorFragmentContext context, StatisticsAggregate config, List<RecordBatch> children)
CloseableRecordBatch	StatisticsMergeBatchCreator.getBatch(ExecutorFragmentContext context, StatisticsMerge config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	StatisticsAggBatch(StatisticsAggregate popConfig, RecordBatch incoming, FragmentContext context)
	StatisticsMergeBatch(StatisticsMerge popConfig, RecordBatch incoming, FragmentContext context)

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

Classes in org.apache.drill.exec.physical.impl.svremover that implement RecordBatch

Modifier and Type	Class	Description
class	RemovingRecordBatch

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

Modifier and Type	Method	Description
static Copier	GenericCopierFactory.createAndSetupCopier(RecordBatch incoming, VectorContainer outputContainer, SchemaChangeCallBack callBack)
static Copier	GenericCopierFactory.createAndSetupNonSVGenericCopier(RecordBatch incoming, VectorContainer outputContainer)

Method parameters in org.apache.drill.exec.physical.impl.svremover with type arguments of type RecordBatch

Modifier and Type	Method	Description
RemovingRecordBatch	SVRemoverCreator.getBatch(ExecutorFragmentContext context, SelectionVectorRemover config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	GenericSV2Copier(RecordBatch incomingBatch, VectorContainer outputContainer, SchemaChangeCallBack callBack)
	GenericSV4Copier(RecordBatch incomingBatch, VectorContainer outputContainer, SchemaChangeCallBack callBack)
	RemovingRecordBatch(SelectionVectorRemover popConfig, FragmentContext context, RecordBatch incoming)
	StraightCopier(RecordBatch incomingBatch, VectorContainer outputContainer, SchemaChangeCallBack callBack)

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

Classes in org.apache.drill.exec.physical.impl.TopN that implement RecordBatch

Modifier and Type	Class	Description
class	TopNBatch	Operator Batch which implements the TopN functionality.
static class	TopNBatch.SimpleSV4RecordBatch

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

Modifier and Type	Method	Description
abstract void	PriorityQueueTemplate.doSetup(VectorContainer incoming, RecordBatch outgoing)	Stores the reference to the hyperBatch container which holds all the records across incoming batches in it.

Method parameters in org.apache.drill.exec.physical.impl.TopN with type arguments of type RecordBatch

Modifier and Type	Method	Description
TopNBatch	TopNSortBatchCreator.getBatch(ExecutorFragmentContext context, TopN config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	TopNBatch(TopN popConfig, FragmentContext context, RecordBatch incoming)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.trace

Classes in org.apache.drill.exec.physical.impl.trace that implement RecordBatch

Modifier and Type	Class	Description
class	TraceRecordBatch	Contains value vectors which are exactly the same as the incoming record batch's value vectors.

Method parameters in org.apache.drill.exec.physical.impl.trace with type arguments of type RecordBatch

Modifier and Type	Method	Description
TraceRecordBatch	TraceBatchCreator.getBatch(ExecutorFragmentContext context, Trace config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	TraceRecordBatch(Trace pop, RecordBatch incoming, FragmentContext context)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.union

Classes in org.apache.drill.exec.physical.impl.union that implement RecordBatch

Modifier and Type	Class	Description
class	UnionAllRecordBatch

Methods in org.apache.drill.exec.physical.impl.union with parameters of type RecordBatch

Modifier and Type	Method	Description
abstract void	UnionAllerTemplate.doSetup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing)
void	UnionAller.setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, List<TransferPair> transfers)
final void	UnionAllerTemplate.setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, List<TransferPair> transfers)

Method parameters in org.apache.drill.exec.physical.impl.union with type arguments of type RecordBatch

Modifier and Type	Method	Description
UnionAllRecordBatch	UnionAllBatchCreator.getBatch(ExecutorFragmentContext context, UnionAll config, List<RecordBatch> children)

Constructor parameters in org.apache.drill.exec.physical.impl.union with type arguments of type RecordBatch

Modifier	Constructor	Description
	UnionAllRecordBatch(UnionAll config, List<RecordBatch> children, FragmentContext context)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.unnest

Classes in org.apache.drill.exec.physical.impl.unnest that implement RecordBatch

Modifier and Type	Class	Description
class	UnnestRecordBatch

Methods in org.apache.drill.exec.physical.impl.unnest with parameters of type RecordBatch

Modifier and Type	Method	Description
void	Unnest.setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, List<TransferPair> transfers)
final void	UnnestImpl.setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, List<TransferPair> transfers)

Method parameters in org.apache.drill.exec.physical.impl.unnest with type arguments of type RecordBatch

Modifier and Type	Method	Description
UnnestRecordBatch	UnnestBatchCreator.getBatch(ExecutorFragmentContext context, UnnestPOP config, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.unorderedreceiver

Classes in org.apache.drill.exec.physical.impl.unorderedreceiver that implement RecordBatch

Modifier and Type	Class	Description
class	UnorderedReceiverBatch

Method parameters in org.apache.drill.exec.physical.impl.unorderedreceiver with type arguments of type RecordBatch

Modifier and Type	Method	Description
UnorderedReceiverBatch	UnorderedReceiverCreator.getBatch(ExecutorFragmentContext context, UnorderedReceiver receiver, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.unpivot

Classes in org.apache.drill.exec.physical.impl.unpivot that implement RecordBatch

Modifier and Type	Class	Description
class	UnpivotMapsRecordBatch	Unpivot maps.

Method parameters in org.apache.drill.exec.physical.impl.unpivot with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	UnpivotMapsBatchCreator.getBatch(ExecutorFragmentContext context, UnpivotMaps config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	UnpivotMapsRecordBatch(UnpivotMaps pop, RecordBatch incoming, FragmentContext context)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.validate

Classes in org.apache.drill.exec.physical.impl.validate that implement RecordBatch

Modifier and Type	Class	Description
class	IteratorValidatorBatchIterator

Methods in org.apache.drill.exec.physical.impl.validate that return RecordBatch

Modifier and Type	Method	Description
RecordBatch	IteratorValidatorBatchIterator.getIncoming()

Methods in org.apache.drill.exec.physical.impl.validate with parameters of type RecordBatch

Modifier and Type	Method	Description
static boolean	BatchValidator.validate(RecordBatch batch)

Method parameters in org.apache.drill.exec.physical.impl.validate with type arguments of type RecordBatch

Modifier and Type	Method	Description
IteratorValidatorBatchIterator	IteratorValidatorCreator.getBatch(ExecutorFragmentContext context, IteratorValidator config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	IteratorValidatorBatchIterator(RecordBatch incoming)
	IteratorValidatorBatchIterator(RecordBatch incoming, boolean isRepeatable)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.values

Method parameters in org.apache.drill.exec.physical.impl.values with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	ValuesBatchCreator.getBatch(ExecutorFragmentContext context, Values subScan, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.physical.impl.window

Classes in org.apache.drill.exec.physical.impl.window that implement RecordBatch

Modifier and Type	Class	Description
class	WindowFrameRecordBatch	support for OVER(PARTITION BY expression1,expression2,...

Method parameters in org.apache.drill.exec.physical.impl.window with type arguments of type RecordBatch

Modifier and Type	Method	Description
WindowFrameRecordBatch	WindowFrameBatchCreator.getBatch(ExecutorFragmentContext context, WindowPOP config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	WindowFrameRecordBatch(WindowPOP popConfig, FragmentContext context, RecordBatch incoming)

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

Classes in org.apache.drill.exec.physical.impl.xsort that implement RecordBatch

Modifier and Type	Class	Description
class	ExternalSortBatch	External sort batch: a sort batch which can spill to disk in order to operate within a defined memory footprint.

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

Modifier and Type	Method	Description
abstract void	MSortTemplate.doSetup(FragmentContext context, VectorContainer incoming, RecordBatch outgoing)
abstract void	SingleBatchSorterTemplate.doSetup(FragmentContext context, VectorAccessible incoming, RecordBatch outgoing)
static void	ExternalSortBatch.releaseBatches(RecordBatch incoming)
static void	ExternalSortBatch.retainSv4OnNone(RecordBatch incoming)	Workaround for DRILL-5656.

Method parameters in org.apache.drill.exec.physical.impl.xsort with type arguments of type RecordBatch

Modifier and Type	Method	Description
AbstractRecordBatch<ExternalSort>	ExternalSortBatchCreator.getBatch(ExecutorFragmentContext context, ExternalSort config, List<RecordBatch> children)

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

Modifier	Constructor	Description
	ExternalSortBatch(ExternalSort popConfig, FragmentContext context, RecordBatch incoming)

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

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

Modifier and Type	Method	Description
static RowSet	RowSets.wrap(RecordBatch batch)

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

Subinterfaces of RecordBatch in org.apache.drill.exec.record

Modifier and Type	Interface	Description
interface	CloseableRecordBatch

Classes in org.apache.drill.exec.record that implement RecordBatch

Modifier and Type	Class	Description
class	AbstractBinaryRecordBatch<T extends PhysicalOperator>
class	AbstractRecordBatch<T extends PhysicalOperator>
class	AbstractSingleRecordBatch<T extends PhysicalOperator>	Implements an AbstractUnaryRecordBatch where the incoming record batch is known at the time of creation
class	AbstractTableFunctionRecordBatch<T extends PhysicalOperator>	Implements AbstractUnaryRecodBatch for operators that do not have an incoming record batch available at creation time; the input is typically set up a few steps after creation.
class	AbstractUnaryRecordBatch<T extends PhysicalOperator>	Base class for operators that have a single input.
class	SchemalessBatch	Empty batch without schema and data.
class	SimpleRecordBatch	Wrap a VectorContainer into a record batch.

Fields in org.apache.drill.exec.record declared as RecordBatch

Modifier and Type	Field	Description
protected final RecordBatch	AbstractSingleRecordBatch.incoming
protected RecordBatch	AbstractTableFunctionRecordBatch.incoming
protected final RecordBatch	AbstractBinaryRecordBatch.left
protected final RecordBatch	AbstractBinaryRecordBatch.right

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

Modifier and Type	Method	Description
protected RecordBatch	AbstractSingleRecordBatch.getIncoming()
protected RecordBatch	AbstractTableFunctionRecordBatch.getIncoming()
protected abstract RecordBatch	AbstractUnaryRecordBatch.getIncoming()

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

Modifier and Type	Method	Description
static String	TypedFieldId.getPath(TypedFieldId typeFieldId, RecordBatch recordBatch)	Generates the full path to a field from the typefield ids
final RecordBatch.IterOutcome	AbstractRecordBatch.next(int inputIndex, RecordBatch b)
final RecordBatch.IterOutcome	AbstractRecordBatch.next(RecordBatch b)
void	AbstractTableFunctionRecordBatch.setIncoming(RecordBatch incoming)
void	TableFunctionContract.setIncoming(RecordBatch incoming)	sets the incoming record batch for the operator.
void	JoinBatchMemoryManager.update(RecordBatch batch, int inputIndex, int outputPosition)	Update the memory manager parameters based on the given (incoming) batch (based on allocated sizes, not average row size)
void	JoinBatchMemoryManager.update(RecordBatch batch, int inputIndex, int outputPosition, boolean useAggregate)	Update the memory manager parameters based on the given (incoming) batch
void	RecordBatchMemoryManager.update(RecordBatch recordBatch)
void	RecordBatchMemoryManager.update(RecordBatch recordBatch, int index)
void	RecordBatchMemoryManager.update(RecordBatch batch, int inputIndex, int outputPosition)
void	RecordBatchMemoryManager.update(RecordBatch batch, int inputIndex, int outputPosition, boolean useAggregate)

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

Modifier	Constructor	Description
protected	AbstractBinaryRecordBatch(T popConfig, FragmentContext context, boolean buildSchema, RecordBatch left, RecordBatch right)
protected	AbstractBinaryRecordBatch(T popConfig, FragmentContext context, RecordBatch left, RecordBatch right)
	AbstractSingleRecordBatch(T popConfig, FragmentContext context, RecordBatch incoming)
	JoinBatchMemoryManager(int outputBatchSize, RecordBatch leftBatch, RecordBatch rightBatch, Set<String> excludedColumns)
	RecordBatchSizer(RecordBatch batch)
	RecordIterator(RecordBatch incoming, AbstractRecordBatch<?> outgoing, OperatorContext oContext, int inputIndex, boolean enableMarkAndReset, RecordBatchMemoryManager callBack)
	RecordIterator(RecordBatch incoming, AbstractRecordBatch<?> outgoing, OperatorContext oContext, int inputIndex, RecordBatchMemoryManager callBack)

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

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

Modifier and Type	Method	Description
void	SelectionVector4Builder.add(RecordBatch batch, boolean newSchema)

Uses of RecordBatch in org.apache.drill.exec.store.delta.read

Method parameters in org.apache.drill.exec.store.delta.read with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	DeltaScanBatchCreator.getBatch(ExecutorFragmentContext context, DeltaRowGroupScan rowGroupScan, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.dfs.easy

Methods in org.apache.drill.exec.store.dfs.easy with parameters of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	EasyFormatPlugin.getWriterBatch(FragmentContext context, RecordBatch incoming, EasyWriter writer)

Method parameters in org.apache.drill.exec.store.dfs.easy with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	EasyReaderBatchCreator.getBatch(ExecutorFragmentContext context, EasySubScan config, List<RecordBatch> children)
CloseableRecordBatch	EasyWriterBatchCreator.getBatch(ExecutorFragmentContext context, EasyWriter config, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.direct

Method parameters in org.apache.drill.exec.store.direct with type arguments of type RecordBatch

Modifier and Type	Method	Description
ScanBatch	DirectBatchCreator.getBatch(ExecutorFragmentContext context, DirectSubScan config, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.drill.plugin

Classes in org.apache.drill.exec.store.drill.plugin that implement RecordBatch

Modifier and Type	Class	Description
class	DrillRecordReader

Method parameters in org.apache.drill.exec.store.drill.plugin with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	DrillScanBatchCreator.getBatch(ExecutorFragmentContext context, DrillSubScan subScan, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.druid

Method parameters in org.apache.drill.exec.store.druid with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	DruidScanBatchCreator.getBatch(ExecutorFragmentContext context, DruidSubScan subScan, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.enumerable

Method parameters in org.apache.drill.exec.store.enumerable with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	EnumerableBatchCreator.getBatch(ExecutorFragmentContext context, EnumerableSubScan subScan, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.googlesheets

Method parameters in org.apache.drill.exec.store.googlesheets with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	GoogleSheetsInsertWriterBatchCreator.getBatch(ExecutorFragmentContext context, GoogleSheetsInsertWriter config, List<RecordBatch> children)
CloseableRecordBatch	GoogleSheetsScanBatchCreator.getBatch(ExecutorFragmentContext context, GoogleSheetsSubScan subScan, List<RecordBatch> children)
CloseableRecordBatch	GoogleSheetsWriterBatchCreator.getBatch(ExecutorFragmentContext context, GoogleSheetsWriter config, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.hbase

Method parameters in org.apache.drill.exec.store.hbase with type arguments of type RecordBatch

Modifier and Type	Method	Description
ScanBatch	HBaseScanBatchCreator.getBatch(ExecutorFragmentContext context, HBaseSubScan subScan, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.hive

Method parameters in org.apache.drill.exec.store.hive with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	HiveDrillNativeParquetScanBatchCreator.getBatch(ExecutorFragmentContext context, HiveDrillNativeParquetRowGroupScan rowGroupScan, List<RecordBatch> children)
ScanBatch	HiveScanBatchCreator.getBatch(ExecutorFragmentContext context, HiveSubScan config, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.http

Method parameters in org.apache.drill.exec.store.http with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	HttpScanBatchCreator.getBatch(ExecutorFragmentContext context, HttpSubScan subScan, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.iceberg.read

Method parameters in org.apache.drill.exec.store.iceberg.read with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	IcebergScanBatchCreator.getBatch(ExecutorFragmentContext context, IcebergSubScan subScan, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.ischema

Method parameters in org.apache.drill.exec.store.ischema with type arguments of type RecordBatch

Modifier and Type	Method	Description
ScanBatch	InfoSchemaBatchCreator.getBatch(ExecutorFragmentContext context, InfoSchemaSubScan config, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.jdbc

Method parameters in org.apache.drill.exec.store.jdbc with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	JdbcInsertWriterBatchCreator.getBatch(ExecutorFragmentContext context, JdbcInsertWriter config, List<RecordBatch> children)
CloseableRecordBatch	JdbcScanBatchCreator.getBatch(ExecutorFragmentContext context, JdbcSubScan subScan, List<RecordBatch> children)
CloseableRecordBatch	JdbcWriterBatchCreator.getBatch(ExecutorFragmentContext context, JdbcWriter config, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.kafka

Method parameters in org.apache.drill.exec.store.kafka with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	KafkaScanBatchCreator.getBatch(ExecutorFragmentContext context, KafkaSubScan subScan, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.kudu

Method parameters in org.apache.drill.exec.store.kudu with type arguments of type RecordBatch

Modifier and Type	Method	Description
ScanBatch	KuduScanBatchCreator.getBatch(ExecutorFragmentContext context, KuduSubScan subScan, List<RecordBatch> children)
CloseableRecordBatch	KuduWriterBatchCreator.getBatch(ExecutorFragmentContext context, KuduWriter config, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.mock

Method parameters in org.apache.drill.exec.store.mock with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	MockScanBatchCreator.getBatch(ExecutorFragmentContext context, MockSubScanPOP config, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.mongo

Method parameters in org.apache.drill.exec.store.mongo with type arguments of type RecordBatch

Modifier and Type	Method	Description
ScanBatch	MongoScanBatchCreator.getBatch(ExecutorFragmentContext context, MongoSubScan subScan, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.openTSDB

Method parameters in org.apache.drill.exec.store.openTSDB with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	OpenTSDBBatchCreator.getBatch(ExecutorFragmentContext context, OpenTSDBSubScan subScan, List<RecordBatch> children)

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

Methods in org.apache.drill.exec.store.parquet with parameters of type RecordBatch

Modifier and Type	Method	Description
WriterRecordBatch	ParquetFormatPlugin.getWriterBatch(FragmentContext context, RecordBatch incoming, ParquetWriter writer)

Method parameters in org.apache.drill.exec.store.parquet with type arguments of type RecordBatch

Modifier and Type	Method	Description
ScanBatch	ParquetScanBatchCreator.getBatch(ExecutorFragmentContext context, ParquetRowGroupScan rowGroupScan, List<RecordBatch> children)
WriterRecordBatch	ParquetWriterBatchCreator.getBatch(ExecutorFragmentContext context, ParquetWriter config, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.phoenix

Method parameters in org.apache.drill.exec.store.phoenix with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	PhoenixScanBatchCreator.getBatch(ExecutorFragmentContext context, PhoenixSubScan subScan, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.splunk

Method parameters in org.apache.drill.exec.store.splunk with type arguments of type RecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	SplunkInsertWriterBatchCreator.getBatch(ExecutorFragmentContext context, SplunkInsertWriter config, List<RecordBatch> children)
CloseableRecordBatch	SplunkScanBatchCreator.getBatch(ExecutorFragmentContext context, SplunkSubScan subScan, List<RecordBatch> children)
CloseableRecordBatch	SplunkWriterBatchCreator.getBatch(ExecutorFragmentContext context, SplunkWriter config, List<RecordBatch> children)

Uses of RecordBatch in org.apache.drill.exec.store.sys

Method parameters in org.apache.drill.exec.store.sys with type arguments of type RecordBatch

Modifier and Type	Method	Description
ScanBatch	SystemTableBatchCreator.getBatch(ExecutorFragmentContext context, SystemTableScan scan, List<RecordBatch> children)

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

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

Modifier and Type	Method	Description
static void	RecordBatchStats.logRecordBatchStats(RecordBatchStats.RecordBatchIOType ioType, String sourceId, RecordBatch recordBatch, RecordBatchStats.RecordBatchStatsContext batchStatsContext)
static void	RecordBatchStats.logRecordBatchStats(RecordBatchStats.RecordBatchIOType ioType, RecordBatch recordBatch, RecordBatchStats.RecordBatchStatsContext batchStatsContext)

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

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

Modifier and Type	Method	Description
static void	VectorValidator.validate(RecordBatch batch)