class PythonScalarFunctionRunner extends AbstractGeneralPythonScalarFunctionRunner<Row> {

	@Override
	@SuppressWarnings("unchecked")
	public RowSerializer getInputTypeSerializer() {
		return (RowSerializer) PythonTypeUtils.toFlinkTypeSerializer(getInputType());
	}

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

}