code: def __init__(self, rank):
      self._rank = rank
  
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 1 to create a new ConsumingActor object  with example: obj = ConsumingActor(rank)