code: def encode_one_hot(value, vector_size):
      vec = [0] * vector_size
      vec[value] = 1
      return vec
  
file_path: pipelinedp/examples/movie_view_ratings/run_all_frameworks.py
imports: from absl import app
  from absl import flags
  from apache_beam.runners.portability import fn_api_runner
  import pyspark
  from examples.movie_view_ratings.common_utils import *
  import pipeline_dp
label_desc: Use image node_id 8 for calling a global function with example usage: encode_one_hot(value, vector_size) and returns: vec