class_docstr: Performs aggregations for utility analysis.
class_docstr_tok: ["Performs","aggregations","for","utility","analysis","."]
code: def __init__(
      self,
      budget_accountant: pipeline_dp.budget_accounting.BudgetAccountant,
      ops: pipeline_dp.pipeline_backend.PipelineBackend,
  ):
      self._budget_accountant = budget_accountant
      self._ops = ops
  
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 1 to create a new PeekerEngine object  with example: obj = PeekerEngine(budget_accountant, ops)