You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@crunch.apache.org by jw...@apache.org on 2013/12/11 21:47:50 UTC
[4/9] Crunch on Spark
http://git-wip-us.apache.org/repos/asf/crunch/blob/6e623413/crunch-spark/src/it/resources/orders.txt
----------------------------------------------------------------------
diff --git a/crunch-spark/src/it/resources/orders.txt b/crunch-spark/src/it/resources/orders.txt
new file mode 100644
index 0000000..d60df82
--- /dev/null
+++ b/crunch-spark/src/it/resources/orders.txt
@@ -0,0 +1,5 @@
+222|Toilet plunger
+333|Toilet brush
+222|Toilet paper
+111|Corn flakes
+555|Not ordered
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/crunch/blob/6e623413/crunch-spark/src/it/resources/org/apache/crunch/SparkCogroupITData/src1.txt
----------------------------------------------------------------------
diff --git a/crunch-spark/src/it/resources/org/apache/crunch/SparkCogroupITData/src1.txt b/crunch-spark/src/it/resources/org/apache/crunch/SparkCogroupITData/src1.txt
new file mode 100644
index 0000000..9f38eb9
--- /dev/null
+++ b/crunch-spark/src/it/resources/org/apache/crunch/SparkCogroupITData/src1.txt
@@ -0,0 +1,4 @@
+a,1-1
+b,1-2
+c,1-3
+a,1-4
http://git-wip-us.apache.org/repos/asf/crunch/blob/6e623413/crunch-spark/src/it/resources/org/apache/crunch/SparkCogroupITData/src2.txt
----------------------------------------------------------------------
diff --git a/crunch-spark/src/it/resources/org/apache/crunch/SparkCogroupITData/src2.txt b/crunch-spark/src/it/resources/org/apache/crunch/SparkCogroupITData/src2.txt
new file mode 100644
index 0000000..ed9524e
--- /dev/null
+++ b/crunch-spark/src/it/resources/org/apache/crunch/SparkCogroupITData/src2.txt
@@ -0,0 +1,4 @@
+b,2-1
+c,2-2
+c,2-3
+d,2-4
http://git-wip-us.apache.org/repos/asf/crunch/blob/6e623413/crunch-spark/src/it/resources/secondary_sort_input.txt
----------------------------------------------------------------------
diff --git a/crunch-spark/src/it/resources/secondary_sort_input.txt b/crunch-spark/src/it/resources/secondary_sort_input.txt
new file mode 100644
index 0000000..3c7be93
--- /dev/null
+++ b/crunch-spark/src/it/resources/secondary_sort_input.txt
@@ -0,0 +1,7 @@
+one,1,1
+one,2,-3
+two,4,5
+two,2,6
+two,1,7,9
+three,0,-1
+one,-5,10
http://git-wip-us.apache.org/repos/asf/crunch/blob/6e623413/crunch-spark/src/it/resources/set1.txt
----------------------------------------------------------------------
diff --git a/crunch-spark/src/it/resources/set1.txt b/crunch-spark/src/it/resources/set1.txt
new file mode 100644
index 0000000..3b67f57
--- /dev/null
+++ b/crunch-spark/src/it/resources/set1.txt
@@ -0,0 +1,4 @@
+b
+c
+a
+e
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/crunch/blob/6e623413/crunch-spark/src/it/resources/set2.txt
----------------------------------------------------------------------
diff --git a/crunch-spark/src/it/resources/set2.txt b/crunch-spark/src/it/resources/set2.txt
new file mode 100644
index 0000000..8169ab5
--- /dev/null
+++ b/crunch-spark/src/it/resources/set2.txt
@@ -0,0 +1,3 @@
+c
+d
+a
\ No newline at end of file