code: def testBucketizationSpecificDistribution(self):
      # Distribution of input values.
      # This distribution is taken from one of the user pipelines.
      dist = (
          # Format: ((<min-value-in-range>, <max-value-in-range>), num-values)
          ((0.51, 0.67), 4013),
          ((0.67, 0.84), 2321),
          ((0.84, 1.01), 7145),
          ((1.01, 1.17), 64524),
          ((1.17, 1.34), 42886),
          ((1.34, 1.51), 154809),
          ((1.51, 1.67), 382678),
          ((1.67, 1.84), 582744),
          ((1.84, 2.01), 252221),
          ((2.01, 2.17), 7299),
      )
  
      inputs = []
      for (mn, mx), num in dist:
          step = (mx - mn) / 100
          for ix in range(num // 100):
              inputs += [mn + (ix * step)]
  
      expected_boundaries = np.array(
          [[2.3084, 3.5638, 5.0972, 7.07]], dtype=np.float32
      )
  
      self._assert_quantile_boundaries(
          inputs, expected_boundaries, tf.float32, num_buckets=5
      )
  
imports: import contextlib
  import random
  import numpy
  import tensorflow
  import tensorflow_transform
  from tensorflow_transform import analyzers
  from tensorflow_transform.beam import impl
  from tensorflow_transform.beam import tft_unit
  from tensorflow_metadata.proto.v0 import schema_pb2
label_desc: Use image node_id 16 for calling the BucketizeIntegrationTest obj's underlying member method code with example usage: obj.testBucketizationSpecificDistribution() without return types