weka.knowledgeflow.steps

Class ArffHeaderSparkJob

java.lang.Object

weka.knowledgeflow.steps.BaseStep

weka.knowledgeflow.steps.AbstractSparkJob

weka.knowledgeflow.steps.ArffHeaderSparkJob

All Implemented Interfaces:

java.io.Serializable, BaseStepExtender, Step

@KFStep(name="ArffHeaderSparkJob",
        category="Spark",
        toolTipText="Makes a unified ARFF header for a dataset ",
        iconPath="weka/gui/knowledgeflow/icons/ARFFHeaderSparkJob.gif")
public class ArffHeaderSparkJob
extends AbstractSparkJob

Knowledge Flow step for the ArffHeader Spark Job

Version:

$Revision: $

Author:

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ArffHeaderSparkJob()

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

ArffHeaderSparkJob

public ArffHeaderSparkJob()

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