weka.distributed.hadoop

Class ItemSimilarityRecommenderHadoopJob

java.lang.Object

distributed.core.DistributedJob

weka.distributed.hadoop.HadoopJob

weka.distributed.hadoop.ItemSimilarityRecommenderHadoopJob

All Implemented Interfaces:

java.io.Serializable, CommandlineRunnable, EnvironmentHandler, OptionHandler

public class ItemSimilarityRecommenderHadoopJob
extends HadoopJob
implements CommandlineRunnable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class distributed.core.DistributedJob

distributed.core.DistributedJob.JobStatus

Field Summary

Fields inherited from class weka.distributed.hadoop.HadoopJob

COLT_JAR, DISTRIBUTED_WEKA_BASE_JAR, DISTRIBUTED_WEKA_HADOOP_JAR, JCOMMON_JAR, JFREECHART_JAR, LA4J_JAR, OPEN_CSV_JAR

Fields inherited from class distributed.core.DistributedJob

WEKA_ADDITIONAL_PACKAGES_KEY

Constructor Summary

Constructors

Constructor and Description
ItemSimilarityRecommenderHadoopJob() Constructor

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getCSVMapTaskOptions() Get the options to the header job
java.lang.String[]	getOptions()
java.lang.String	getRecommenderMapTaskOptions()
java.lang.String	globalInfo() Help information
java.util.Enumeration<Option>	listOptions()
static void	main(java.lang.String[] args)
void	run(java.lang.Object toRun, java.lang.String[] options)
boolean	runJob()
void	setCSVMapTaskOptions(java.lang.String opts) Set the options to the header job
void	setOptions(java.lang.String[] options)
void	setRecommenderMapTaskOptions(java.lang.String opts)

Methods inherited from class weka.distributed.hadoop.HadoopJob

additionalWekaPackagesTipText, cleanOutputDirectory, deubgTipText, getAdditionalWekaPackages, getBaseOptionsOnly, getDebug, getLoggingInterval, getMapNumber, getMapReduceJobConfig, getMapReduceNumber, getPathToWekaJar, getReduceNumber, loggingIntervalTipText, pathToWekaJarTipText, setAdditionalWekaPackages, setDebug, setLoggingInterval, setMapReduceJobConfig, setPathToWekaJar

Methods inherited from class distributed.core.DistributedJob

environmentSubstitute, getAdditionalWekaPackageNames, getJobName, getJobStatus, getLog, makeOptionsStr, parseInstance, setEnvironment, setJobDescription, setJobName, setJobStatus, setLog, setStatusMessagePrefix, stopJob

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ItemSimilarityRecommenderHadoopJob

public ItemSimilarityRecommenderHadoopJob()

Constructor

Method Detail

globalInfo

public java.lang.String globalInfo()

Help information

Returns:

help information for this job

setCSVMapTaskOptions

public void setCSVMapTaskOptions(java.lang.String opts)

Set the options to the header job

Parameters:

opts - options to the header job

getCSVMapTaskOptions

public java.lang.String getCSVMapTaskOptions()

Get the options to the header job

Returns:

options to the header job

setRecommenderMapTaskOptions

public void setRecommenderMapTaskOptions(java.lang.String opts)

getRecommenderMapTaskOptions

public java.lang.String getRecommenderMapTaskOptions()

listOptions

public java.util.Enumeration<Option> listOptions()

Specified by:

listOptions in interface OptionHandler

Overrides:

listOptions in class HadoopJob

setOptions

public void setOptions(java.lang.String[] options)
                throws java.lang.Exception

Specified by:

setOptions in interface OptionHandler

Overrides:

setOptions in class HadoopJob

Throws:

java.lang.Exception

getOptions

public java.lang.String[] getOptions()

Specified by:

getOptions in interface OptionHandler

Overrides:

getOptions in class HadoopJob

runJob

public boolean runJob()
               throws weka.distributed.DistributedWekaException

Specified by:

runJob in class distributed.core.DistributedJob

Throws:

weka.distributed.DistributedWekaException

run

public void run(java.lang.Object toRun,
       java.lang.String[] options)

Specified by:

run in interface CommandlineRunnable

main

public static void main(java.lang.String[] args)