code: def get_pre_process_text_ds_iter(
      text_ds,
      pipeline_func,
      num_parallel_calls,
      batch_size,
  ):
      """Get pre-process oprators."""
  
      text_ds = text_ds.map(
          pipeline_func, num_parallel_calls=num_parallel_calls
      )
  
      text_ds = text_ds.batch(batch_size)
  
      iterator = tf.data.make_initializable_iterator(text_ds)
  
      return iterator
  
file_path: delta/delta/data/preprocess/utils.py
imports: import os
  import pickle
  import collections
  import numpy
  from absl import logging
  import delta.compat
  from delta.data.utils.vocabulary import Vocabulary
label_desc: Use image node_id 1 for calling a global function with example usage: get_pre_process_text_ds_iter(text_ds, pipeline_func, num_parallel_calls, batch_size) and returns: iterator