I would like to find out how many data copies are occurred when getting an object from Plasma. An example:
import pandas import ray ray.init() df = pandas.DataFrame([1, 2, 3]) o_ref = ray.put(df) df2 = ray.get(o_ref) @ray.remote def foo(): df3 = ray.get(o_ref) ... foo.remote()
df2 be a copy of
df at the driver process and
df3 at the worker process (2 copies)?
Thanks in advance!