Frontend / Python API Query Planner & Optimizer Ray Core / Distributed Workers lazy evaluation unoptimized optimized schedule tasks df.read_images() .map(resize) .filter(is_dog) LOGICAL_PLAN_AST RULE: FILTER_PUSHDOWN PHYSICAL_DAG RAY_WORKER_01 [read -> filter -> resize] RAY_WORKER_02 [read -> filter -> resize]