class OperatorRecordBatch implements CloseableRecordBatch {

  @Override
  public void cancel() {
    driver.cancel();
  }

  public  OperatorRecordBatch(FragmentContext context, PhysicalOperator config,
      OperatorExec opExec, boolean enableSchemaBatch);

}