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.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.window
org.apache.drill.exec.physical.impl.xsort
org.apache.drill.exec.record
org.apache.drill.exec.store.dfs.easy
org.apache.drill.exec.store.druid
org.apache.drill.exec.store.enumerable
org.apache.drill.exec.store.hive
org.apache.drill.exec.store.http
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.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 and 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 and Description
class	MockRecordBatch
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 and 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 and 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 and 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 and 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 and 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 and Description
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 and 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 and 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 and 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 and 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 and 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 and 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 and 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 and 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 and 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.sort

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

Modifier and Type	Class and 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 and 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 and 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 and 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 and 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 and 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 and 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 and Description
class	MockLateralJoinBatch A mock lateral join implementation for testing unnest.
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 and 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 and Description
class	UnpivotMapsRecordBatch Unpivot maps.

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

Modifier and Type	Method and 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 and Description
class	IteratorValidatorBatchIterator

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 and 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 and 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 and 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.dfs.easy

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

Modifier and Type	Method and Description
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.druid

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

Modifier and Type	Method and 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 and Description
CloseableRecordBatch	EnumerableBatchCreator.getBatch(ExecutorFragmentContext context, EnumerableSubScan subScan, 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 and 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 and Description
CloseableRecordBatch	HttpScanBatchCreator.getBatch(ExecutorFragmentContext context, HttpSubScan subScan, 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 and 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 and 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 and 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 and Description
CloseableRecordBatch	OpenTSDBBatchCreator.getBatch(ExecutorFragmentContext context, OpenTSDBSubScan 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 and Description
CloseableRecordBatch	SplunkScanBatchCreator.getBatch(ExecutorFragmentContext context, SplunkSubScan subScan, List<RecordBatch> children)