code: def create_pandas_over_window_aggregate_function(
      factory, transform_id, transform_proto, parameter, consumers
  ):
      return _create_user_defined_function_operation(
          factory,
          transform_proto,
          consumers,
          parameter,
          beam_operations.StatelessFunctionOperation,
          table_operations.PandasBatchOverWindowAggregateFunctionOperation,
      )
  
imports: from apache_beam.portability import common_urns
  from apache_beam.portability.api import beam_runner_api_pb2
  from apache_beam.runners import common
  from apache_beam.runners.worker import bundle_processor, operation_specs
  from apache_beam.utils import proto_utils
  from pyflink import fn_execution
  from pyflink.fn_execution import flink_fn_execution_pb2
  from pyflink.fn_execution.coders import from_proto, from_type_info_proto, TimeWindowCoder, CountWindowCoder, FlattenRowCoder
  from pyflink.fn_execution.state_impl import RemoteKeyedStateBackend, RemoteOperatorStateBackend
  import pyflink.fn_execution.datastream.operations
  from pyflink.fn_execution.datastream.process import operations
  import pyflink.fn_execution.table.operations
label_desc: Use image node_id 7 for calling a global function with example usage: create_pandas_over_window_aggregate_function(factory, transform_id, transform_proto, parameter, consumers) and returns: _create_user_defined_function_operation