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