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