code: def parse_line(line, movie_id):
      # 'line' has format "user_id,rating,date"
      split_parts = line.split(",")
      user_id = int(split_parts[0])
      rating = int(split_parts[1])
      return MovieView(user_id, movie_id, rating)
  
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 1 for calling a global function with example usage: parse_line(line, movie_id) and returns: MovieView