public class DruidScanBatchCreator extends Object implements BatchCreator<DruidSubScan>
Constructor and Description |
---|
DruidScanBatchCreator() |
Modifier and Type | Method and Description |
---|---|
CloseableRecordBatch |
getBatch(ExecutorFragmentContext context,
DruidSubScan subScan,
List<RecordBatch> children) |
public CloseableRecordBatch getBatch(ExecutorFragmentContext context, DruidSubScan subScan, List<RecordBatch> children) throws ExecutionSetupException
getBatch
in interface BatchCreator<DruidSubScan>
ExecutionSetupException
Copyright © 2021 The Apache Software Foundation. All rights reserved.