public class KF
extends org.pentaho.di.trans.step.BaseStep
implements org.pentaho.di.trans.step.StepInterface, weka.gui.beans.TextListener, weka.gui.beans.DataSourceListener, weka.gui.beans.TrainingSetListener, weka.gui.beans.TestSetListener, weka.gui.beans.BatchAssociationRulesListener, weka.gui.beans.IncrementalClassifierListener, weka.gui.beans.BatchClassifierListener
Constructor and Description |
---|
KF(org.pentaho.di.trans.step.StepMeta stepMeta,
org.pentaho.di.trans.step.StepDataInterface stepDataInterface,
int copyNr,
org.pentaho.di.trans.TransMeta transMeta,
org.pentaho.di.trans.Trans trans)
Creates a new
KF instance. |
Modifier and Type | Method and Description |
---|---|
void |
acceptAssociationRules(weka.gui.beans.BatchAssociationRulesEvent e) |
void |
acceptClassifier(weka.gui.beans.BatchClassifierEvent e) |
void |
acceptClassifier(weka.gui.beans.IncrementalClassifierEvent e) |
void |
acceptDataSet(weka.gui.beans.DataSetEvent e)
Accept a DataSetEvent from the knowledge flow.
|
void |
acceptTestSet(weka.gui.beans.TestSetEvent e)
Accept a TestSetEvent from the knowledge flow.
|
void |
acceptText(weka.gui.beans.TextEvent e)
Accept a text event output from the knowledge flow.
|
void |
acceptTrainingSet(weka.gui.beans.TrainingSetEvent e)
Accept a TraniningSetEvent from the knowledge flow.
|
boolean |
init(org.pentaho.di.trans.step.StepMetaInterface smi,
org.pentaho.di.trans.step.StepDataInterface sdi)
Initialize the step.
|
boolean |
processRow(org.pentaho.di.trans.step.StepMetaInterface smi,
org.pentaho.di.trans.step.StepDataInterface sdi)
Process an incoming row of data.
|
addResultFile, addRowListener, addRowSetToInputRowSets, addRowSetToOutputRowSets, addStepListener, batchComplete, buildLog, canProcessOneRow, checkFeedback, cleanup, clearInputRowSets, clearOutputRowSets, closeQuietly, copyVariablesFrom, decrementLinesRead, decrementLinesWritten, dispatch, dispose, environmentSubstitute, environmentSubstitute, fieldSubstitute, findInputRowSet, findInputRowSet, findOutputRowSet, findOutputRowSet, getBooleanValueOfVariable, getClusterSize, getContainerObjectId, getCopy, getCurrentInputRowSetNr, getCurrentOutputRowSetNr, getDispatcher, getErrorRowMeta, getErrors, getExtensionDataMap, getFilename, getFirstInputRowSet, getInputRowMeta, getInputRowSets, getLinesInput, getLinesOutput, getLinesRead, getLinesRejected, getLinesSkipped, getLinesUpdated, getLinesWritten, getLogChannel, getLogChannelId, getLogFields, getLogLevel, getMetaStore, getNextClassNr, getObjectCopy, getObjectId, getObjectName, getObjectRevision, getObjectType, getOutputRowSets, getParent, getParentVariableSpace, getPartitionID, getPartitionTargets, getPreviewRowMeta, getProcessed, getRegistrationDate, getRemoteInputSteps, getRemoteOutputSteps, getRepartitioning, getRepository, getRepositoryDirectory, getResultFiles, getRow, getRowFrom, getRowHandler, getRowListeners, getRuntime, getServerSockets, getSlaveNr, getSocketRepository, getStatus, getStatusDescription, getStepDataInterface, getStepID, getStepListeners, getStepMeta, getStepMetaInterface, getStepname, getTrans, getTransMeta, getTypeId, getUniqueStepCountAcrossSlaves, getUniqueStepNrAcrossSlaves, getVariable, getVariable, handleGetRowFrom, handlePutRowTo, identifyErrorOutput, incrementLinesInput, incrementLinesOutput, incrementLinesRead, incrementLinesRejected, incrementLinesSkipped, incrementLinesUpdated, incrementLinesWritten, initBeforeStart, initializeVariablesFrom, injectVariables, isBasic, isDebug, isDetailed, isDistributed, isForcingSeparateLogging, isGatheringMetrics, isInitialising, isMapping, isPartitioned, isPaused, isRowLevel, isRunning, isSafeStopped, isStopped, isUsingThreadPriorityManagment, listVariables, logBasic, logBasic, logDebug, logDebug, logDetailed, logDetailed, logError, logError, logError, logMinimal, logMinimal, logRowlevel, logRowlevel, logSummary, markStart, markStop, openRemoteInputStepSocketsOnce, openRemoteOutputStepSocketsOnce, outputIsDone, pauseRunning, putError, putRow, putRowTo, removeRowListener, resumeRunning, rowsetInputSize, rowsetOutputSize, safeModeChecking, safeModeChecking, setCarteObjectId, setCopy, setCurrentInputRowSetNr, setCurrentOutputRowSetNr, setDistributed, setErrorRowMeta, setErrors, setForcingSeparateLogging, setGatheringMetrics, setInputRowMeta, setInputRowSets, setInternalVariables, setLinesInput, setLinesOutput, setLinesRead, setLinesRejected, setLinesSkipped, setLinesUpdated, setLinesWritten, setLogLevel, setMetaStore, setOutputDone, setOutputRowSets, setParentVariableSpace, setPartitioned, setPartitionID, setPartitionTargets, setPaused, setPaused, setPreviewRowMeta, setRepartitioning, setRepository, setRowHandler, setRunning, setSafeStopped, setServerSockets, setSocketRepository, setStepDataInterface, setStepListeners, setStepMeta, setStepMetaInterface, setStepname, setStopped, setTransMeta, setUsingThreadPriorityManagment, setVariable, shareVariablesWith, stopAll, stopRunning, stopRunning, swapFirstInputRowSetIfExists, toString, verifyInputDeadLock, waitUntilTransformationIsStarted
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addRowListener, addRowSetToInputRowSets, addRowSetToOutputRowSets, addStepListener, batchComplete, canProcessOneRow, cleanup, dispose, getCopy, getCurrentInputRowSetNr, getCurrentOutputRowSetNr, getErrors, getInputRowSets, getLinesInput, getLinesOutput, getLinesRead, getLinesRejected, getLinesUpdated, getLinesWritten, getLogChannel, getMetaStore, getOutputRowSets, getPartitionID, getProcessed, getRepository, getResultFiles, getRow, getRowListeners, getRuntime, getStatus, getStepID, getStepMeta, getStepname, getTrans, identifyErrorOutput, initBeforeStart, isMapping, isPartitioned, isPaused, isRunning, isSafeStopped, isStopped, isUsingThreadPriorityManagment, markStart, markStop, pauseRunning, putRow, removeRowListener, resumeRunning, rowsetInputSize, rowsetOutputSize, setCurrentInputRowSetNr, setCurrentOutputRowSetNr, setErrors, setLinesRejected, setMetaStore, setOutputDone, setPartitioned, setPartitionID, setRepartitioning, setRepository, setRunning, setSafeStopped, setStopped, setUsingThreadPriorityManagment, stopAll, stopRunning, subStatuses
copyVariablesFrom, environmentSubstitute, environmentSubstitute, fieldSubstitute, getBooleanValueOfVariable, getParentVariableSpace, getVariable, getVariable, initializeVariablesFrom, injectVariables, listVariables, setParentVariableSpace, setVariable, shareVariablesWith
public KF(org.pentaho.di.trans.step.StepMeta stepMeta, org.pentaho.di.trans.step.StepDataInterface stepDataInterface, int copyNr, org.pentaho.di.trans.TransMeta transMeta, org.pentaho.di.trans.Trans trans)
KF
instance.stepMeta
- holds the step's meta datastepDataInterface
- holds the step's temporary datacopyNr
- the number assigned to the steptransMeta
- meta data for the transformationtrans
- a Trans
valuepublic boolean processRow(org.pentaho.di.trans.step.StepMetaInterface smi, org.pentaho.di.trans.step.StepDataInterface sdi) throws org.pentaho.di.core.exception.KettleException
processRow
in interface org.pentaho.di.trans.step.StepInterface
processRow
in class org.pentaho.di.trans.step.BaseStep
smi
- a StepMetaInterface
valuesdi
- a StepDataInterface
valueboolean
valueorg.pentaho.di.core.exception.KettleException
- if an error occurspublic void acceptClassifier(weka.gui.beans.IncrementalClassifierEvent e)
acceptClassifier
in interface weka.gui.beans.IncrementalClassifierListener
public void acceptClassifier(weka.gui.beans.BatchClassifierEvent e)
acceptClassifier
in interface weka.gui.beans.BatchClassifierListener
public void acceptAssociationRules(weka.gui.beans.BatchAssociationRulesEvent e)
acceptAssociationRules
in interface weka.gui.beans.BatchAssociationRulesListener
public void acceptText(weka.gui.beans.TextEvent e)
acceptText
in interface weka.gui.beans.TextListener
e
- the TextEvent to processpublic void acceptTrainingSet(weka.gui.beans.TrainingSetEvent e)
acceptTrainingSet
in interface weka.gui.beans.TrainingSetListener
e
- the TrainingSetEvent to processpublic void acceptTestSet(weka.gui.beans.TestSetEvent e)
acceptTestSet
in interface weka.gui.beans.TestSetListener
e
- the TestSetEvent to processpublic void acceptDataSet(weka.gui.beans.DataSetEvent e)
acceptDataSet
in interface weka.gui.beans.DataSourceListener
e
- the DataSetEvent to processpublic boolean init(org.pentaho.di.trans.step.StepMetaInterface smi, org.pentaho.di.trans.step.StepDataInterface sdi)
init
in interface org.pentaho.di.trans.step.StepInterface
init
in class org.pentaho.di.trans.step.BaseStep
smi
- a StepMetaInterface
valuesdi
- a StepDataInterface
valueboolean
valueCopyright © 2002–2019 Hitachi Vantara. All rights reserved.