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

Packages that use CloseableRecordBatch

Package	Description
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.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.mergereceiver
org.apache.drill.exec.physical.impl.metadata
org.apache.drill.exec.physical.impl.orderedpartitioner
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.record
org.apache.drill.exec.store.delta.read
org.apache.drill.exec.store.dfs.easy
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.hive
org.apache.drill.exec.store.http
org.apache.drill.exec.store.iceberg.read
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.openTSDB
org.apache.drill.exec.store.phoenix
org.apache.drill.exec.store.splunk

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

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

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

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

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

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 CloseableRecordBatch

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

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

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

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

Uses of CloseableRecordBatch in org.apache.drill.exec.physical.impl.filter

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

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

Methods in org.apache.drill.exec.physical.impl.filter that return CloseableRecordBatch

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

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

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

Modifier and Type	Class	Description
class	FlattenRecordBatch

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

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

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

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

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

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

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

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

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

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

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

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.

Methods in org.apache.drill.exec.physical.impl.metadata that return CloseableRecordBatch

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)

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

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

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

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

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

Modifier and Type	Class	Description
class	ProducerConsumerBatch

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

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

Modifier and Type	Class	Description
class	ProjectRecordBatch

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

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

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

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

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

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).

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

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

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

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

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

Modifier and Type	Class	Description
class	SortBatch

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

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

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

Methods in org.apache.drill.exec.physical.impl.statistics that return CloseableRecordBatch

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)

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

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

Modifier and Type	Class	Description
class	RemovingRecordBatch

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

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

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

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

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

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

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

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

Modifier and Type	Class	Description
class	UnionAllRecordBatch

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

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

Modifier and Type	Class	Description
class	UnnestRecordBatch

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

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

Modifier and Type	Class	Description
class	UnorderedReceiverBatch

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

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

Modifier and Type	Class	Description
class	UnpivotMapsRecordBatch	Unpivot maps.

Methods in org.apache.drill.exec.physical.impl.unpivot that return CloseableRecordBatch

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

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

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

Modifier and Type	Class	Description
class	IteratorValidatorBatchIterator

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

Methods in org.apache.drill.exec.physical.impl.values that return CloseableRecordBatch

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

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

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

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

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

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

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.

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

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

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.

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

Methods in org.apache.drill.exec.store.delta.read that return CloseableRecordBatch

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

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

Methods in org.apache.drill.exec.store.dfs.easy that return CloseableRecordBatch

Modifier and Type	Method	Description
CloseableRecordBatch	ClassicScanBuilder.build()
CloseableRecordBatch	EasyReaderBatchCreator.getBatch(ExecutorFragmentContext context, EasySubScan config, List<RecordBatch> children)
CloseableRecordBatch	EasyWriterBatchCreator.getBatch(ExecutorFragmentContext context, EasyWriter config, List<RecordBatch> children)
protected CloseableRecordBatch	EasyFormatPlugin.getReaderBatch(FragmentContext context, EasySubScan scan)
CloseableRecordBatch	EasyFormatPlugin.getWriterBatch(FragmentContext context, RecordBatch incoming, EasyWriter writer)

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

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

Modifier and Type	Class	Description
class	DrillRecordReader

Methods in org.apache.drill.exec.store.drill.plugin that return CloseableRecordBatch

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

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

Methods in org.apache.drill.exec.store.druid that return CloseableRecordBatch

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

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

Methods in org.apache.drill.exec.store.enumerable that return CloseableRecordBatch

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

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

Methods in org.apache.drill.exec.store.googlesheets that return CloseableRecordBatch

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 CloseableRecordBatch in org.apache.drill.exec.store.hive

Methods in org.apache.drill.exec.store.hive that return CloseableRecordBatch

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

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

Methods in org.apache.drill.exec.store.http that return CloseableRecordBatch

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

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

Methods in org.apache.drill.exec.store.iceberg.read that return CloseableRecordBatch

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

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

Methods in org.apache.drill.exec.store.jdbc that return CloseableRecordBatch

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 CloseableRecordBatch in org.apache.drill.exec.store.kafka

Methods in org.apache.drill.exec.store.kafka that return CloseableRecordBatch

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

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

Methods in org.apache.drill.exec.store.kudu that return CloseableRecordBatch

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

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

Methods in org.apache.drill.exec.store.mock that return CloseableRecordBatch

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

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

Methods in org.apache.drill.exec.store.openTSDB that return CloseableRecordBatch

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

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

Methods in org.apache.drill.exec.store.phoenix that return CloseableRecordBatch

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

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

Methods in org.apache.drill.exec.store.splunk that return CloseableRecordBatch

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)