public class PartitionLimitBatchCreator extends Object implements BatchCreator<PartitionLimit>
Constructor and Description |
---|
PartitionLimitBatchCreator() |
Modifier and Type | Method and Description |
---|---|
PartitionLimitRecordBatch |
getBatch(ExecutorFragmentContext context,
PartitionLimit config,
List<RecordBatch> children) |
public PartitionLimitRecordBatch getBatch(ExecutorFragmentContext context, PartitionLimit config, List<RecordBatch> children) throws ExecutionSetupException
getBatch
in interface BatchCreator<PartitionLimit>
ExecutionSetupException
Copyright © 1970 The Apache Software Foundation. All rights reserved.