Ray parallel worked, working on stream compaction