[ https://issues.apache.org/jira/browse/MAHOUT-612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sean Owen updated MAHOUT-612: ----------------------------- Component/s: Collaborative Filtering Classification Fix Version/s: 0.6 Looking good, marking for 0.6 > Simplify configuring and running Mahout MapReduce jobs from Java using Java > bean configuration > ---------------------------------------------------------------------------------------------- > > Key: MAHOUT-612 > URL: https://issues.apache.org/jira/browse/MAHOUT-612 > Project: Mahout > Issue Type: Improvement > Components: Classification, Clustering, Collaborative Filtering > Affects Versions: 0.4, 0.5 > Reporter: Frank Scholten > Assignee: Sean Owen > Fix For: 0.6 > > Attachments: MAHOUT-612-canopy.patch, MAHOUT-612-kmeans.patch, > MAHOUT-612-v2.patch, MAHOUT-612.patch > > > Most of the Mahout features require running several jobs in sequence. This > can be done via the command line or using one of the driver classes. > Running and configuring a Mahout job from Java requires using either the > Driver's static methods or creating a String array of parameters and pass > them to the main method of the job. If we can instead configure jobs through > a Java bean or factory we it will be type safe and easier to use in by DI > frameworks such as Spring and Guice. > I have added a patch where I factored out a KMeans MapReduce job plus a > configuration Java bean, from KMeansDriver.buildClustersMR(...) > * The KMeansMapReduceConfiguration takes care of setting up the correct > values in the Hadoop Configuration object and initializes defaults. I copied > the config keys from KMeansConfigKeys. > * The KMeansMapReduceJob contains the code for the actual algorithm running > all iterations of KMeans and returns the KMeansMapReduceConfiguration, which > contains the cluster path for the final iteration. > I like to extend this approach to other Hadoop jobs for instance the job for > creating points in KMeansDriver, but I first want some feedback on this. > One of the benefits of this approach is that it becomes easier to chain jobs. > For instance we can chain Canopy to KMeans by connecting the output dir of > Canopy's configuration to the input dir of the configuration of the KMeans > job next in the chain. Hadoop's JobControl class can then be used to connect > and execute the entire chain. > This approach can be further improved by turning the configuration bean into > a factory for creating MapReduce or sequential jobs. This would probably > remove some duplicated code in the KMeansDriver. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira