code: def consume(
      self,
      split,
      use_gpu=False,
      max_bytes_to_read=None,
  ):
      do_consume(
          split,
          self._rank,
          use_gpu,
          max_bytes_to_read,
      )
  
file_path: ray/release/nightly_tests/dataset/data_ingest_benchmark.py
imports: import numpy
  import sys
  import time
  import argparse
  from benchmark import Benchmark
  import ray
  from ray.data import Dataset
  from ray.data import DatasetPipeline
  import pandas
  import torch
label_desc: Use image node_id 2 for calling the ConsumingActor obj's underlying member method code with example usage: obj.consume(split, use_gpu, max_bytes_to_read) without return types