code: def test_prioritized_table(self):
      table_name = "test_prioritized_table"
      queue_table = reverb.Table(
          table_name,
          sampler=reverb.selectors.Prioritized(1.0),
          remover=reverb.selectors.Fifo(),
          rate_limiter=reverb.rate_limiters.MinSize(1),
          max_size=3,
      )
      reverb_server = reverb.Server([queue_table])
      data_spec = tensor_spec.TensorSpec((), dtype=tf.int64)
      replay = reverb_replay_buffer.ReverbReplayBuffer(
          data_spec,
          table_name,
          sequence_length=1,
          local_server=reverb_server,
          dataset_buffer_size=1,
      )
  
      with replay.py_client.trajectory_writer(1) as writer:
          for i in range(3):
              writer.append(i)
              writer.create_item(
                  table_name, trajectory=writer.history[-1:], priority=i
              )
  
      dataset = replay.as_dataset(
          sample_batch_size=1, num_steps=None, num_parallel_calls=1
      )
  
      iterator = iter(dataset)
      counts = [0] * 3
      for i in range(1000):
          item_0 = next(iterator)[
              0
          ].numpy()  # This is a matrix shaped 1x1.
          counts[int(item_0)] += 1
  
      self.assertEqual(counts[0], 0)  # priority 0
      self.assertGreater(counts[1], 250)  # priority 1
      self.assertGreater(counts[2], 600)
  
imports: from __future__ import absolute_import
  from __future__ import division
  from __future__ import print_function
  import contextlib
  import functools
  import time
  from absl.testing import parameterized
  import mock
  import reverb
  from six.moves import range
  import tensorflow
  from tf_agents.drivers import py_driver
  from tf_agents.environments import parallel_py_environment
  from tf_agents.environments import test_envs
  from tf_agents.policies import random_py_policy
  from tf_agents.replay_buffers import reverb_replay_buffer
  from tf_agents.replay_buffers import reverb_utils
  from tf_agents.specs import tensor_spec
  from tf_agents.system import system_multiprocessing
  from tf_agents.trajectories import time_step
  from tf_agents.utils import test_utils
label_desc: Use image node_id 4 for calling the ReverbTableTests obj's underlying member method code with example usage: obj.test_prioritized_table() without return types