Re-write correllation to work across the cluster