Interface BatchCreator<T extends PhysicalOperator>
- All Known Implementing Classes:
ComplexToJsonBatchCreator
,DeltaScanBatchCreator
,DirectBatchCreator
,DrillScanBatchCreator
,DruidScanBatchCreator
,EasyReaderBatchCreator
,EasyWriterBatchCreator
,EnumerableBatchCreator
,ExternalSortBatchCreator
,FilterBatchCreator
,FlattenBatchCreator
,GoogleSheetsInsertWriterBatchCreator
,GoogleSheetsScanBatchCreator
,GoogleSheetsWriterBatchCreator
,HashAggBatchCreator
,HashJoinBatchCreator
,HBaseScanBatchCreator
,HiveDrillNativeParquetScanBatchCreator
,HiveScanBatchCreator
,HttpScanBatchCreator
,IcebergScanBatchCreator
,InfoSchemaBatchCreator
,IteratorValidatorCreator
,JdbcInsertWriterBatchCreator
,JdbcScanBatchCreator
,JdbcWriterBatchCreator
,KafkaScanBatchCreator
,KuduScanBatchCreator
,KuduWriterBatchCreator
,LateralJoinBatchCreator
,LimitBatchCreator
,MergeJoinCreator
,MergingReceiverCreator
,MetadataControllerBatchCreator
,MetadataHandlerBatchCreator
,MetadataHashAggBatchCreator
,MetadataStreamAggBatchCreator
,MockScanBatchCreator
,MongoScanBatchCreator
,NestedLoopJoinBatchCreator
,OpenTSDBBatchCreator
,ParquetScanBatchCreator
,ParquetWriterBatchCreator
,PartitionLimitBatchCreator
,PhoenixScanBatchCreator
,ProducerConsumerBatchCreator
,ProjectBatchCreator
,RowKeyJoinBatchCreator
,RuntimeFilterBatchCreator
,SchemalessBatchCreator
,SetOpBatchCreator
,SortBatchCreator
,SplunkInsertWriterBatchCreator
,SplunkScanBatchCreator
,SplunkWriterBatchCreator
,StatisticsAggBatchCreator
,StatisticsMergeBatchCreator
,StreamingAggBatchCreator
,SVRemoverCreator
,SystemTableBatchCreator
,TopNSortBatchCreator
,TraceBatchCreator
,UnionAllBatchCreator
,UnnestBatchCreator
,UnorderedReceiverCreator
,UnpivotMapsBatchCreator
,ValuesBatchCreator
,WindowFrameBatchCreator
public interface BatchCreator<T extends PhysicalOperator>
-
Method Summary
Modifier and TypeMethodDescriptiongetBatch
(ExecutorFragmentContext context, T config, List<RecordBatch> children)
-
Method Details
-
getBatch
CloseableRecordBatch getBatch(ExecutorFragmentContext context, T config, List<RecordBatch> children) throws ExecutionSetupException - Throws:
ExecutionSetupException
-