code: def _join_with_movies(
      datapipe: IterDataPipe, root: str
  ) -> IterDataPipe:
      movies_path = os.path.join(root, MOVIES_FILENAME)
      movies_datapipe = LoadFiles((movies_path,), mode="r")
      movies_datapipe = ReadLinesFromCSV(
          movies_datapipe,
          skip_first_line=True,
          delimiter=",",
      )
      movie_id_to_movie: Dict[str, List[str]] = {
          row[0]: row[1:] for row in movies_datapipe
      }
  
      def join_rating_movie(val: List[str]) -> List[str]:
          return val + movie_id_to_movie[val[1]]
  
      return datapipe.map(join_rating_movie)
  
file_path: torchrec/torchrec/datasets/movielens.py
imports: import os
  from typing import Any, Callable, Dict, List, Optional, Union
  from torch.utils.data import IterDataPipe
  from torchrec.datasets.utils import LoadFiles, ReadLinesFromCSV, safe_cast
label_desc: Use image node_id 2 for calling a global function with example usage: _join_with_movies(datapipe, root) and returns: datapipe, unknown