ceteri

bash-3.2$ elastic-mapreduce --create --name "Sample Recommender" \
>   --jar s3n://temp.cascading.org/sample/recommender.jar \
>     --arg s3n://temp.cascading.org/sample/en.stop \
>     --arg s3n://temp.cascading.org/sample/tweets/ \
>     --arg s3n://temp.cascading.org/sample/out/token \
>     --arg s3n://temp.cascading.org/sample/out/similarity
Created job flow j-2HA2BVCBJGMVX
bash-3.2$ elastic-mapreduce --list
j-2HA2BVCBJGMVX     STARTING                                                         Sample Recommender
   PENDING        Example Jar Step              

ceteri

public class
  Main
  {
  public static void
  main( String[] args )
    {
    String inPath = args[ 0 ];
    String outPath = args[ 1 ];

    Properties properties = new Properties();

ceteri

12/05/14 14:42:57 INFO multitool.Main: key: source
12/05/14 14:42:58 INFO multitool.Main: key: expr
12/05/14 14:42:58 INFO multitool.Main: key: gen
12/05/14 14:42:58 INFO multitool.Main: key: group
12/05/14 14:42:58 INFO multitool.Main: key: count
12/05/14 14:42:58 INFO multitool.Main: key: group
12/05/14 14:42:58 INFO multitool.Main: key: sink
12/05/14 14:43:01 INFO util.HadoopUtil: resolving application jar from found main method on: multitool.Main
12/05/14 14:43:01 INFO planner.HadoopPlanner: using application jar: /Users/paco/src/concur/cascading.multitool/./build/multitool.jar
12/05/14 14:43:01 INFO property.AppProps: using app.id: 1C9D0188E5018B980067AAC12AE43BBA

zeeshanlakhani

#Code from http://fmota.eu/, great!
class Monoid:
	def __init__(self, null, lift, op):
		self.null = null
		self.lift = lift
		self.op   = op

	def fold(self, xs):
		if hasattr(xs, "__fold__"):
			return xs.__fold__(self)