code: def process_file(f, dst):
      data = pd.read_parquet(f)
      data = data[DEFAULT_COLUMN_NAMES]
  
      data[DEFAULT_LABEL_NAME] = data[DEFAULT_LABEL_NAME].astype(
          np.int32
      )
      data[DEFAULT_INT_NAMES] = data[DEFAULT_INT_NAMES].astype(
          np.float32
      )
      data[DEFAULT_CAT_NAMES] = data[DEFAULT_CAT_NAMES].astype(np.int32)
  
      data = data.to_records(index=False)
      data = data.tobytes()
  
      dst_file = dst + "/" + f.split("/")[-1] + ".bin"
      with open(dst_file, "wb") as dst_fd:
          dst_fd.write(data)
  
file_path: torchrec/torchrec/datasets/scripts/nvt/convert_parquet_to_binary.py
imports: import argparse
  import glob
  import os
  import time
  import numpy
  import pandas
  import tqdm
  from joblib import delayed, Parallel
  from utils.criteo_constant import DEFAULT_CAT_NAMES, DEFAULT_COLUMN_NAMES, DEFAULT_INT_NAMES, DEFAULT_LABEL_NAME
label_desc: Use image node_id 1 for calling a global function with example usage: process_file(f, dst) without return types