code: def _cross_partition_filter_fn(
      max_partitions: int, col: Tuple[Any, int, int]
  ) -> bool:
      _, per_user_aggregated_value, partition_count = col
      if per_user_aggregated_value <= max_partitions:
          return True
      # This is an approximation of true cross partition bounding.
      return np.random.rand() < max_partitions / partition_count
  
file_path: pipelinedp/utility_analysis/peeker_engine.py
imports: import functools
  from typing import Any, Sequence, Tuple, Union
  from apache_beam import pvalue
  import numpy
  import pydp
  import pipeline_dp
label_desc: Use image node_id 2 for calling a global function with example usage: _cross_partition_filter_fn(max_partitions, col) and returns: unknown, True