Uses of Class
weka.knowledgeflow.Data
-
Uses of Data in weka.knowledgeflow
Modifier and TypeMethodDescriptionJobEnvironment.getResultData()
Get a map of all the result data objectsJobEnvironment.getResultDataOfType
(String connName) Get a list of any result data objects of the supplied connection typeModifier and TypeMethodDescriptionvoid
JobEnvironment.addToResult
(Data data) Add a non-incremental data object to the resultboolean
StepOutputListener.dataFromStep
(Data data) Process data produced by a knowledge flow stepvoid
StepInjectorFlowRunner.injectStreaming
(Data toInject, Step target, boolean lastData) Inject streaming data into the target step in the flowvoid
StepInjectorFlowRunner.injectWithExecutionFinishedCallback
(Data toInject, ExecutionFinishedCallback callback, Step target) Inject data into the flowboolean
StepManager.isStreamFinished
(Data data) Returns true if this data object marks the end of an incremental stream.boolean
StepManagerImpl.isStreamFinished
(Data data) Returns true if this data object marks the end of an incremental stream.void
StepManager.outputData
(String outgoingConnectionName, String stepName, Data data) Output a single Data object to the named step with the supplied outgoing connection typevoid
StepManager.outputData
(String outgoingConnectionName, Data data) Output data to all steps connected with the supplied outgoing connection type.void
StepManager.outputData
(Data... data) Output one or more Data objects to all relevant steps.void
StepManagerImpl.outputData
(String outgoingConnectionName, String stepName, Data data) Outputs the supplied Data object to the named Step.void
StepManagerImpl.outputData
(String outgoingConnectionName, Data data) Output a Data object to all downstream connected Steps that are connected with the supplied connection name.void
StepManagerImpl.outputData
(Data... data) Output one or more Data objects to all relevant steps.void
StepManager.throughputFinished
(Data... data) Signal that throughput measurement has finished.void
StepManagerImpl.throughputFinished
(Data... data) Clients can use this to indicate that throughput measuring is finished (i.e.Modifier and TypeMethodDescriptionvoid
JobEnvironment.addAllResults
(Map<String, LinkedHashSet<Data>> otherResults) Add all the results from the supplied map to this environment's results -
Uses of Data in weka.knowledgeflow.steps
Modifier and TypeMethodDescriptionBaseSimpleDataVisualizer.getDatasets()
Get the datasets seen so farModifier and TypeMethodDescriptionvoid
Initiate routing and processing for a particular data objectvoid
AlterRelationName.processIncoming
(Data data) Process incoming datavoid
Appender.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
ASEvaluator.processIncoming
(Data data) Process an incoming Data objectvoid
Associator.processIncoming
(Data data) Processes incoming datavoid
AttributeSummarizer.processIncoming
(Data data) Process incoming datavoid
BaseSimpleDataVisualizer.processIncoming
(Data data) Process incoming datavoid
BaseStep.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
BaseStepExtender.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections).void
Block.processIncoming
(Data data) Process incoming datavoid
BoundaryPlotter.processIncoming
(Data data) void
ClassAssigner.processIncoming
(Data data) Process incoming datavoid
Classifier.processIncoming
(Data data) void
ClassifierPerformanceEvaluator.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
ClassValuePicker.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
Clusterer.processIncoming
(Data data) Process an incoming data objectvoid
ClustererPerformanceEvaluator.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
CostBenefitAnalysis.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
CrossValidationFoldMaker.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
DataVisualizer.processIncoming
(Data data) void
ExecuteProcess.processIncoming
(Data data) Process an incoming Data objectvoid
Filter.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
FlowByExpression.processIncoming
(Data data) Main processing routinevoid
GetDataFromResult.processIncoming
(Data data) void
GraphViewer.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
ImageSaver.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
ImageViewer.processIncoming
(Data data) Process incoming image datavoid
IncrementalClassifierEvaluator.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
InstanceStreamToBatchMaker.processIncoming
(Data data) Process incoming datavoid
Job.processIncoming
(Data data) void
Join.processIncoming
(Data data) Process some incoming datavoid
MakeResourceIntensive.processIncoming
(Data data) Process incoming datavoid
ModelPerformanceChart.processIncoming
(Data data) Process incoming datavoid
PredictionAppender.processIncoming
(Data data) Process incoming datavoid
Saver.processIncoming
(Data data) Processes incoming datavoid
SendToPerspective.processIncoming
(Data data) void
SerializedModelSaver.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
SetVariables.processIncoming
(Data data) void
Sorter.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
Step.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
StorePropertiesInEnvironment.processIncoming
(Data data) void
StripChart.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
SubstringLabeler.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
SubstringReplacer.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
TestSetMaker.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
TextSaver.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
TextViewer.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
TrainingSetMaker.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
TrainTestSplitMaker.processIncoming
(Data data) Process an incoming data payload (if the step accepts incoming connections)void
WriteDataToResult.processIncoming
(Data data) void
WriteWekaLog.processIncoming
(Data data) Process an incoming piece of dataClassifier.processPrimary
(Integer setNum, Integer maxSetNum, Data data, PairedDataHelper<Classifier> helper) Process a training split (primary data handled by the PairedDataHelper)Clusterer.processPrimary
(Integer setNum, Integer maxSetNum, Data data, PairedDataHelper<Clusterer> helper) Process a training split (primary data handled by the PairedDataHelper)PairedDataHelper.PairedProcessor.processPrimary
(Integer setNum, Integer maxSetNum, Data data, PairedDataHelper<P> helper) void
Classifier.processSecondary
(Integer setNum, Integer maxSetNum, Data data, PairedDataHelper<Classifier> helper) Process a test split/fold (secondary data handled by PairedDataHelper)void
Clusterer.processSecondary
(Integer setNum, Integer maxSetNum, Data data, PairedDataHelper<Clusterer> helper) Process a test split/fold (secondary data handled by PairedDataHelper)void
PairedDataHelper.PairedProcessor.processSecondary
(Integer setNum, Integer maxSetNum, Data data, PairedDataHelper<P> helper)