%NODE_NAME% = spark.read.csv(%SRC_NODE_NAME%_item, sep=%DELIMITER%)