code: def process(self, line):
      if line[-1] == ":":
          # 'line' has a format "movie_id:'
          self.movie_id = int(line[:-1])
          return
      # 'line' has a format "user_id,rating,date"
      yield parse_line(line, self.movie_id)
  
file_path: pipelinedp/examples/movie_view_ratings/common_utils.py
imports: from dataclasses import dataclass
  import os
  import shutil
  from typing import List, Any
  import apache_beam
label_desc: Use image node_id 2 for calling the ParseFile obj's underlying member method code with example usage: obj.process(line) without return types