Example on Incorporating MATLAB Map and Reduce Functions into a Hadoop Job
Supported Platform: Linux® only.
This example shows you how to use the
mcc command to create a
deployable archive consisting of MATLAB® map and reduce functions and then pass the deployable archive as a
payload argument to a job submitted to a Hadoop® cluster.
Goal: Calculate the maximum arrival delay of an airline from the given dataset.
Airline departure and arrival information from 1987-2008.
When compared to the Hadoop Compiler app workflow, this workflow requires the explicit creation of a Hadoop settings file. Follow the example for details.
Start this example by creating a new work folder that is visible to the MATLAB search path.
Before starting MATLAB, at a terminal, set the environment variable
HADOOP_PREFIXto point to the Hadoop installation folder. For example:
Shell Command csh / tcsh
% setenv HADOOP_PREFIX /usr/lib/hadoop
$ export HADOOP_PREFIX=/usr/lib/hadoop
This example uses
/usr/lib/hadoopas directory where Hadoop is installed. Your Hadoop installation directory maybe different.
If you forget setting the
HADOOP_PREFIXenvironment variable prior to starting MATLAB, set it up using the MATLAB function
setenvat the MATLAB command prompt as soon as you start MATLAB. For example:
Install the MATLAB Runtime in a folder that is accessible by every worker node in the Hadoop cluster. This example uses
/usr/local/MATLAB/MATLAB_Runtime/v911as the location of the MATLAB Runtime folder.
If you don’t have the MATLAB Runtime, you can download it from the website at:
For information about MATLAB Runtime version numbers corresponding MATLAB releases, see this list.
Copy the map function
/usr/local/MATLAB/R2021b/toolbox/matlab/demosfolder to the work folder.
For more information, see Write a Map Function.
Copy the reduce function
folder to the work folder.
For more information, see Write a Reduce Function.
Create the directory
/user/on HDFS™ and copy the file
airlinesmall.csvto that directory. Here
refers to your user name in HDFS.
$ ./hadoop fs -copyFromLocal airlinesmall.csv hdfs://host:54310/user/
Start MATLAB and verify that the
HADOOP_PREFIXenvironment variable has been set. At the command prompt, type:
ansis empty, review the Prerequisites section above to see how you can set the
datastoreto the file
airlinesmall.csvand save it to a
datastoreobject is meant to capture the structure of your actual dataset on HDFS.
ds = datastore('airlinesmall.csv','TreatAsMissing','NA',... 'SelectedVariableNames','ArrDelay','ReadSize',1000); save('infoAboutDataset.mat','ds')
In most cases, you will start off by working on a small sample dataset residing on a local machine that is representative of the actual dataset on the cluster. This sample dataset has the same structure and variables as the actual dataset on the cluster. By creating a
datastoreobject to the dataset residing on your local machine you are taking a snapshot of that structure. By having access to this
datastoreobject, a Hadoop job executing on the cluster will know how to access and process the actual dataset residing on HDFS.
In this example, the sample dataset (local) and the actual dataset on HDFS are the same.
Create a configuration file (
config.txt) that specifies the input type of the data, the format of the data specified by the
datastorecreated in the previous step, the output type of the data, the name of map function, and the name of reduce function.For more information, see Configuration File for Creating Deployable Archive Using the mcc Command.
mw.ds.in.type = tabulartext mw.ds.in.format = infoAboutDataset.mat mw.ds.out.type = keyvalue mw.mapper = maxArrivalDelayMapper mw.reducer = maxArrivalDelayReducer
mcccommand with the
-mflag to create a deployable archive. The
-mflag creates a standard executable that can be run from a command line. However, the
mcccommand cannot package the results in an installer. The command must be entered as a single line.
mcc -H -W 'hadoop:maxArrivalDelay,CONFIG:config.txt' maxArrivalDelayMapper.m maxArrivalDelayReducer.m -a infoAboutDataset.mat
For more information, see
MATLAB Compiler™ creates a shell script
run_maxarrivaldelay.sh, a deployable archive
airlinesmall.ctf, and a log file
Incorporate the deployable archive containing MATLAB map and reduce functions into a Hadoop mapreduce job from a Linux shell using the following command:
$ hadoop \ jar /usr/local/MATLAB/MATLAB_Runtime/v911/toolbox/mlhadoop/jar/a2.2.0/mwmapreduce.jar \ com.mathworks.hadoop.MWMapReduceDriver \ -D mw.mcrroot=/usr/local/MATLAB/MATLAB_Runtime/v911 \ maxArrivalDelay.ctf \ hdfs://host:54310/user/
<username>/datasets/airlinesmall.csv \ hdfs://host:54310/user/
Alternately, you can incorporate the deployable archive containing MATLAB map and reduce functions into a Hadoop mapreduce job using the shell script generated by the Hadoop Compiler app. At the Linux shell type the following command:
$ ./run_maxArrivalDelay.sh \ /usr/local/MATLAB/MATLAB_Runtime/v911 \ -D mw.mcrroot=/usr/local/MATLAB/MATLAB_Runtime/v911 \ hdfs://host:54310/user/username/datasets/airlinesmall.csv \ hdfs://host:54310/user/
To examine the results, switch to the MATLAB desktop and create a
datastoreto the results on HDFS. You can then view the results using the
d = datastore('hdfs:///user/<username>/results/part*'); read(d)
ans = Key Value _________________ ______ 'MaxArrivalDelay' 
Other examples of
are available at
toolbox/matlab/demos folder. You can use other
examples to prototype similar deployable archives that run against Hadoop. For more information, see Build Effective Algorithms with MapReduce.