code: def get_input_from_sample(self, epochs):
      def _parse_func(line):
          data = tf.string_split([line], ",")
          return data
  
      dataset = tf.data.TextLineDataset(self.params["sample_dir"])
      dataset = dataset.map(_parse_func)
      dataset = dataset.batch(self.params["batch_size"]).repeat(epochs)
      source = dataset.make_one_shot_iterator().get_next()
      return source
  
file_path: euler/euler_estimator/python/sample_estimator.py
imports: from __future__ import absolute_import
  from __future__ import division
  from __future__ import print_function
  import tensorflow
  import tf_euler
  from euler_estimator.python.base_estimator import BaseEstimator
label_desc: Use image node_id 2 for calling the SampleEstimator obj's underlying member method code with example usage: obj.get_input_from_sample(epochs) and returns: source, data