Added pairRdd/create/*.py

Author: Pedro Bernardo

pairRdd/create/PairRddFromRegularRdd.py

@@ -0,0 +1,12 @@
+from pyspark import SparkContext
+
+if __name__ == "__main__":
+
+    sc = SparkContext("local", "create")
+    sc.setLogLevel("ERROR")
+
+    inputStrings = ["Lily 23", "Jack 29", "Mary 29", "James 8"]
+    regularRDDs = sc.parallelize(inputStrings)
+
+    pairRDD = regularRDDs.map(lambda s: (s.split(" ")[0], s.split(" ")[1]))
+    pairRDD.coalesce(1).saveAsTextFile("out/pair_rdd_from_regular_rdd")

pairRdd/create/PairRddFromTupleList.py

@@ -0,0 +1,11 @@
+from pyspark import SparkContext
+
+if __name__ == "__main__":
+
+    sc = SparkContext("local", "create")
+    sc.setLogLevel("ERROR")
+
+    tuples = [("Lily", 23), ("Jack", 29), ("Mary", 29), ("James", 8)]
+    pairRDD = sc.parallelize(tuples)
+
+    pairRDD.coalesce(1).saveAsTextFile("out/pair_rdd_from_tuple_list")