class PythonTableFunctionRunner extends AbstractPythonTableFunctionRunner<Row> {

	@Override
	public TypeSerializer<Row> getInputTypeSerializer() {
		return (RowSerializer) PythonTypeUtils.toFlinkTypeSerializer(getInputType());
	}

	public  PythonTableFunctionRunner(
		String taskName,
		FnDataReceiver<byte[]> resultReceiver,
		PythonFunctionInfo tableFunction,
		PythonEnvironmentManager environmentManager,
		RowType inputType,
		RowType outputType);

}