class BatchArrowPythonGroupAggregateFunctionOperator extends AbstractBatchArrowPythonAggregateFunctionOperator {

	@Override
	public void open() throws Exception {
		userDefinedFunctionOutputType = new RowType(
			outputType.getFields().subList(groupingSet.length, outputType.getFieldCount()));
		super.open();
	}

	public  BatchArrowPythonGroupAggregateFunctionOperator(
		Configuration config,
		PythonFunctionInfo[] pandasAggFunctions,
		RowType inputType,
		RowType outputType,
		int[] groupKey,
		int[] groupingSet,
		int[] udafInputOffsets);

}