Package weka.gui.beans
Class FlowRunner
- java.lang.Object
-
- weka.gui.beans.FlowRunner
-
- All Implemented Interfaces:
RevisionHandler
public class FlowRunner extends java.lang.Object implements RevisionHandler
Small utility class for executing KnowledgeFlow flows outside of the KnowledgeFlow application- Version:
- $Revision: 7059 $
- Author:
- Mark Hall (mhall{[at]}pentaho{[dot]}org)
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
FlowRunner.SimpleLogger
-
Constructor Summary
Constructors Constructor Description FlowRunner()
Constructor
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Environment
getEnvironment()
Get the environment variables that are in use.java.util.Vector
getFlows()
Get the vector holding the flow(s)java.lang.String
getRevision()
Returns the revision string.boolean
getStartSequentially()
Gets whether Startable beans will be launched sequentially or all in parallel.void
load(java.lang.String fileName)
Load a serialized KnowledgeFlow (either binary or xml)void
loadBinary(java.lang.String fileName)
Load a binary serialized KnowledgeFlowvoid
loadXML(java.lang.String fileName)
Load an XML serialized KnowledgeFlowstatic void
main(java.lang.String[] args)
Main method for testing this class.void
run()
Launch all loaded KnowledgeFlowvoid
setEnvironment(Environment env)
Set the environment variables to use.void
setFlows(java.util.Vector beans)
Set the vector holding the flows(s) to runvoid
setLog(Logger log)
void
setStartSequentially(boolean s)
Set whether to launch Startable beans one after the other or all in parallel.void
stopAllFlows()
void
waitUntilFinished()
Waits until all flows have finished executing before returning
-
-
-
Method Detail
-
setLog
public void setLog(Logger log)
-
stopAllFlows
public void stopAllFlows()
-
waitUntilFinished
public void waitUntilFinished()
Waits until all flows have finished executing before returning
-
load
public void load(java.lang.String fileName) throws java.lang.Exception
Load a serialized KnowledgeFlow (either binary or xml)- Parameters:
fileName
- the name of the file to load from- Throws:
java.lang.Exception
- if something goes wrong
-
loadBinary
public void loadBinary(java.lang.String fileName) throws java.lang.Exception
Load a binary serialized KnowledgeFlow- Parameters:
fileName
- the name of the file to load from- Throws:
java.lang.Exception
- if something goes wrong
-
loadXML
public void loadXML(java.lang.String fileName) throws java.lang.Exception
Load an XML serialized KnowledgeFlow- Parameters:
fileName
- the name of the file to load from- Throws:
java.lang.Exception
- if something goes wrong
-
getFlows
public java.util.Vector getFlows()
Get the vector holding the flow(s)- Returns:
- the Vector holding the flow(s)
-
setFlows
public void setFlows(java.util.Vector beans)
Set the vector holding the flows(s) to run- Parameters:
beans
- the Vector holding the flows to run
-
setEnvironment
public void setEnvironment(Environment env)
Set the environment variables to use. NOTE: this needs to be called BEFORE a load method is invoked to ensure that the ${Internal.knowledgeflow.directory} variable get set in the supplied Environment object.- Parameters:
env
- the environment variables to use.
-
getEnvironment
public Environment getEnvironment()
Get the environment variables that are in use.- Returns:
- the environment variables that are in ues.
-
setStartSequentially
public void setStartSequentially(boolean s)
Set whether to launch Startable beans one after the other or all in parallel.- Parameters:
s
- true if Startable beans are to be launched sequentially
-
getStartSequentially
public boolean getStartSequentially()
Gets whether Startable beans will be launched sequentially or all in parallel.- Returns:
- true if Startable beans will be launched sequentially
-
run
public void run() throws java.lang.Exception
Launch all loaded KnowledgeFlow- Throws:
java.lang.Exception
- if something goes wrong during execution
-
main
public static void main(java.lang.String[] args)
Main method for testing this class.
Usage:
Usage:\n\nFlowRunner
- Parameters:
args
- command line arguments
-
getRevision
public java.lang.String getRevision()
Description copied from interface:RevisionHandler
Returns the revision string.- Specified by:
getRevision
in interfaceRevisionHandler
- Returns:
- the revision
-
-