test.sh

#!/bin/bash
lua mapreduce/test.lua

if [[ $? -ne 0 ]]; then
    echo "ERROR"
    exit 1
fi
for storage in gridfs shared sshfs; do
    echo COMBINER + ASSOCIATIVE COMMUTATIVE IDEMPOTENT REDUCER
    screen -d -m ./execute_example_worker.sh
    diff <(./execute_example_server.sh $storage | awk '{ print $1,$2 }' | sort) \
        <(cat mapreduce/server.lua \
        mapreduce/worker.lua \
        mapreduce/test.lua \
        mapreduce/utils.lua | lua misc/naive.lua | awk '{ print $1,$2 }' | sort) > /dev/null
    if [[ $? -ne 0 ]]; then
        echo "ERROR"
        exit 1
    fi
    echo NO COMBINER + ASSOCIATIVE COMMUTATIVE IDEMPOTENT REDUCER
    screen -d -m ./execute_example_worker.sh
    diff <(lua execute_server.lua localhost wordcount \
        mapreduce.examples.WordCount.taskfn \
        mapreduce.examples.WordCount.mapfn \
        mapreduce.examples.WordCount.partitionfn \
        mapreduce.examples.WordCount.reducefn \
        mapreduce.examples.WordCount.finalfn \
        nil $storage | awk '{ print $1,$2 }' | sort) \
        <(cat mapreduce/server.lua \
        mapreduce/worker.lua \
        mapreduce/test.lua \
        mapreduce/utils.lua | lua misc/naive.lua | awk '{ print $1,$2 }' | sort) > /dev/null
    if [[ $? -ne 0 ]]; then
        echo "ERROR"
        exit 1
    fi
    echo NO COMBINER + GENERAL REDUCER
    screen -d -m ./execute_example_worker.sh
    diff <(lua execute_server.lua localhost wordcount \
        mapreduce.examples.WordCount.taskfn \
        mapreduce.examples.WordCount.mapfn \
        mapreduce.examples.WordCount.partitionfn \
        mapreduce.examples.WordCount.reducefn2 \
        mapreduce.examples.WordCount.finalfn \
        nil $storage | awk '{ print $1,$2 }' | sort) \
        <(cat mapreduce/server.lua \
        mapreduce/worker.lua \
        mapreduce/test.lua \
        mapreduce/utils.lua | lua misc/naive.lua | awk '{ print $1,$2 }' | sort) > /dev/null
    if [[ $? -ne 0 ]]; then
        echo "ERROR"
        exit 1
    fi
    echo INIT SCRIPT
    screen -d -m ./execute_example_worker.sh
    diff <(lua execute_server.lua localhost wordcount \
        mapreduce.examples.WordCount \
        mapreduce.examples.WordCount \
        mapreduce.examples.WordCount \
        mapreduce.examples.WordCount \
        mapreduce.examples.WordCount \
        mapreduce.examples.WordCount \
        $storage | awk '{ print $1,$2 }' | sort) \
        <(cat mapreduce/server.lua \
        mapreduce/worker.lua \
        mapreduce/test.lua \
        mapreduce/utils.lua | lua misc/naive.lua | awk '{ print $1,$2 }' | sort) > /dev/null
    if [[ $? -ne 0 ]]; then
        echo "ERROR"
        exit 1
    fi
    echo "Ok with storage $storage"
done