weka.knowledgeflow.steps

Class WekaClassifierSparkJob

java.lang.Object

weka.knowledgeflow.steps.BaseStep

weka.knowledgeflow.steps.AbstractSparkJob

weka.knowledgeflow.steps.WekaClassifierSparkJob

All Implemented Interfaces:

java.io.Serializable, BaseStepExtender, Step

@KFStep(name="WekaClassifierSparkJob",
        category="Spark",
        toolTipText="Builds and an aggregated Weka classifier - produces a single model of the same type for Aggregateable classifiers or a voted ensemble of the base classifier if they are not Aggregateable.",
        iconPath="weka/gui/knowledgeflow/icons/WekaClassifierSparkJob.gif")
public class WekaClassifierSparkJob
extends AbstractSparkJob

Knowledge Flow step for the Weka classifier Spark job

Version:

$Revision: $

Author:

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WekaClassifierSparkJob() Constructor

Method Summary

Modifier and Type	Method and Description
java.util.List<java.lang.String>	getOutgoingConnectionTypes()
void	notifyJobOutputConnections() Notifies listeners of output from this job.

Methods inherited from class weka.knowledgeflow.steps.AbstractSparkJob

getCustomEditorForStep, getIncomingConnectionTypes, getJobOptions, getUnderlyingJob, processIncoming, setJobOptions, setLast, start, stepInit, stop

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

WekaClassifierSparkJob

public WekaClassifierSparkJob()

Constructor

Method Detail

getOutgoingConnectionTypes

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

Specified by:

getOutgoingConnectionTypes in interface BaseStepExtender

Specified by:

getOutgoingConnectionTypes in interface Step

Overrides:

getOutgoingConnectionTypes in class AbstractSparkJob

notifyJobOutputConnections

public void notifyJobOutputConnections()
                                throws WekaException

Description copied from class: AbstractSparkJob

Notifies listeners of output from this job. Subclasses need to override this if they have specific output connections for various data types

Throws:

WekaException - if a problem occurs