code: def test_aggregate_true(self):
      input_data = range(100)
      params = data_peeker.SampleParams(
          number_of_sampled_partitions=10,
          metrics=[pipeline_dp.Metrics.COUNT],
      )
      data_extractor = pipeline_dp.DataExtractors(
          privacy_id_extractor=lambda x: f"pid{x}",
          partition_extractor=lambda x: f"pk{x%10}",
          value_extractor=lambda x: x,
      )
      results = self._peeker.aggregate_true(
          input_data, params, data_extractor
      )
      key_to_v = collections.defaultdict(list)
      for pk, pv in results:
          key_to_v[pk].append(pv)
          self.assertEqual(pv[0], 10)
      self.assertLen(key_to_v.keys(), 10)
  
file_path: pipelinedp/utility_analysis/tests/data_peeker_test.py
imports: import collections
  from absl.testing import absltest
  from absl.testing import parameterized
  import pipeline_dp
  from utility_analysis import data_peeker
label_desc: Use image node_id 4 for calling the DataPeekerTest obj's underlying member method code with example usage: obj.test_aggregate_true() without return types