git commit: [SPARK-2042] Prevent unnecessary shuffle triggered by take()

2014-06-11 Thread marmbrus
Repository: spark Updated Branches: refs/heads/branch-1.0 684a93a72 -> cc004488d [SPARK-2042] Prevent unnecessary shuffle triggered by take() This PR implements `take()` on a `SchemaRDD` by inserting a logical limit that is followed by a `collect()`. This is also accompanied by adding a catal

git commit: [SPARK-2042] Prevent unnecessary shuffle triggered by take()

2014-06-11 Thread marmbrus
Repository: spark Updated Branches: refs/heads/master 4d5c12aa1 -> 4107cce58 [SPARK-2042] Prevent unnecessary shuffle triggered by take() This PR implements `take()` on a `SchemaRDD` by inserting a logical limit that is followed by a `collect()`. This is also accompanied by adding a catalyst