weka.knowledgeflow.steps

Class AbstractHadoopJob

java.lang.Object

weka.knowledgeflow.steps.BaseStep

weka.knowledgeflow.steps.AbstractHadoopJob

All Implemented Interfaces:

java.io.Serializable, BaseStepExtender, Step

Direct Known Subclasses:

CorrelationMatrixHadoopJob, CSVToARFFHadoopJob, KMeansClustererHadoopJob, RandomizedDataChunkHadoopJob, WekaClassifierEvaluationHadoopJob, WekaClassifierHadoopJob, WekaScoringHadoopJob

public abstract class AbstractHadoopJob
extends BaseStep

Base class for Knowledge Flow Hadoop steps

Version:

$Revision: $

Author:

Mark Hall (mhall{[at]}pentaho{[dot]}com)

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AbstractHadoopJob()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getCustomEditorForStep()
java.util.List<java.lang.String>	getIncomingConnectionTypes()
java.lang.String	getJobOptions() Get the options for the underlying job
java.util.List<java.lang.String>	getOutgoingConnectionTypes()
HadoopJob	getUnderlyingJob() Returns the underlying HadoopJob object
void	processIncoming(Data data)
void	setJobOptions(java.lang.String opts) Set the options for the underlying job
void	start()
void	stepInit()
void	stop()
void	updateUnderlyingJob(HadoopJob job) Update the underlying HadoopJob

Methods inherited from class weka.knowledgeflow.steps.BaseStep

environmentSubstitute, getDefaultSettings, getInteractiveViewers, getInteractiveViewersImpls, getName, getStepManager, globalInfo, isResourceIntensive, isStopRequested, outputStructureForConnectionType, setName, setStepIsResourceIntensive, setStepManager, setStepMustRunSingleThreaded, stepMustRunSingleThreaded

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractHadoopJob

public AbstractHadoopJob()

Method Detail

getUnderlyingJob

public HadoopJob getUnderlyingJob()

Returns the underlying HadoopJob object

Returns:

the underlying HadoopJob object

updateUnderlyingJob

public void updateUnderlyingJob(HadoopJob job)

Update the underlying HadoopJob

Parameters:

job - the HadoopJob to update with

setJobOptions

public void setJobOptions(java.lang.String opts)

Set the options for the underlying job

Parameters:

opts - options for the underlying job

getJobOptions

public java.lang.String getJobOptions()

Get the options for the underlying job

Returns:

options for the underlying job

getIncomingConnectionTypes

public java.util.List<java.lang.String> getIncomingConnectionTypes()

getOutgoingConnectionTypes

public java.util.List<java.lang.String> getOutgoingConnectionTypes()

getCustomEditorForStep

public java.lang.String getCustomEditorForStep()

Specified by:

getCustomEditorForStep in interface Step

Overrides:

getCustomEditorForStep in class BaseStep

stepInit

public void stepInit()
              throws WekaException

Throws:

WekaException

start

public void start()
           throws WekaException

Specified by:

start in interface BaseStepExtender

Specified by:

start in interface Step

Overrides:

start in class BaseStep

Throws:

WekaException

stop

public void stop()

Specified by:

stop in interface Step

Overrides:

stop in class BaseStep

processIncoming

public void processIncoming(Data data)
                     throws WekaException

Specified by:

processIncoming in interface BaseStepExtender

Specified by:

processIncoming in interface Step

Overrides:

processIncoming in class BaseStep

Throws:

WekaException