Package weka.knowledgeflow
package weka.knowledgeflow
-
ClassDescriptionBase class for execution environmentsDefaults for the base execution environmentInterface to something that can notify a Step that a Task submitted by ExecutionEnvironment.submitTask() has finished.Class for encapsulating data to be transferred between Knowledge Flow steps over a particular connection type.Default implementation of a CallbackNotifierDelegate.Implementation of a CallbackNotifierDelegate that stores the ExecutionResult and only notifies the callback when the notifyNow() method is called.Client (i.e.Callback interface for receiving notification of a flow finishing executionStores the result generated by a StepTask.Class that encapsulates the Steps involved in a Knowledge Flow process.Interface to something that can execute a Knowledge Flow processInterface to something that can load a Knowledge FlowA FlowExecutor that can launch start points in a flow in parallel or sequentially.A simple logging implementation that writes to standard outExtended Environment with support for storing results and property values to be set at a later date on the base schemes of WekaAlgorithmWrapper steps.Flow loader that wraps the routines in JSONFlowUtilsUtilities for building and saving flows from JSON dataDefault settings for the Knowledge FlowFlow loader that reads legacy .kfml files and translates them to the new implementation.Enum for different logging levelsClass that wraps a
weka.gui.Logger
and filters log messages according to the set logging level.Class annotation that can be used to indicate that something should be executed in a non-parallel manner - i.e.A flow runner that runs a flow by injecting data into a target stepClient public interface for the StepManager.Concrete implementation of the StepManager interface.Inteface to something that listens to the output from aStep
StepTask<T>A task that can be executed by the ExecutionEnvironment's submitTask() service.Callback that Steps can use when executing StepTasks via EnvironmentManager.submitTask().