Package mgui.pipelines
Class PipelineState
java.lang.Object
mgui.pipelines.PipelineState
public class PipelineState
extends java.lang.Object
Represents the state of a pipeline.
- Since:
- 1.0
- Version:
- 1.0
- Author:
- Andrew Reid
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
PipelineState.ErrorStreamListener
-
Field Summary
Fields Modifier and Type Field Description protected foxtrot.WorkerThread
current_worker_thread
java.lang.Throwable
exception
boolean
fail_on_exception
java.lang.String
input_file
java.lang.String
output_file
InterfacePipeline
pipeline
java.lang.String
root_dir
boolean
taskInterrupted
int
temp_count
java.lang.String
temp_input
java.lang.String
temp_output
-
Constructor Summary
Constructors Constructor Description PipelineState(InterfacePipeline pipeline)
Construct a new pipeline state for the given pipeline. -
Method Summary
Modifier and Type Method Description boolean
deleteTempFiles()
void
exceptionEncountered(java.lang.Throwable exception)
java.lang.String
getTempInputPath()
java.lang.String
getTempOutputPath()
boolean
isTaskFailed()
boolean
isTaskInterrupted()
void
reset()
void
setCurrentWorkerThread(foxtrot.WorkerThread thread)
void
setTaskFailed(boolean value)
void
setTaskInterrupted(boolean value)
boolean
stopExecution()
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Field Details
-
output_file
public java.lang.String output_file -
root_dir
public java.lang.String root_dir -
input_file
public java.lang.String input_file -
temp_input
public java.lang.String temp_input -
temp_output
public java.lang.String temp_output -
temp_count
public int temp_count -
fail_on_exception
public boolean fail_on_exception -
taskInterrupted
public boolean taskInterrupted -
pipeline
-
current_worker_thread
protected foxtrot.WorkerThread current_worker_thread -
exception
public java.lang.Throwable exception
-
-
Constructor Details
-
PipelineState
Construct a new pipeline state for the given pipeline.- Parameters:
pipeline
-
-
-
Method Details
-
reset
public void reset() -
stopExecution
public boolean stopExecution() -
setCurrentWorkerThread
public void setCurrentWorkerThread(foxtrot.WorkerThread thread) -
getTempInputPath
public java.lang.String getTempInputPath() -
getTempOutputPath
public java.lang.String getTempOutputPath() -
deleteTempFiles
public boolean deleteTempFiles() -
isTaskInterrupted
public boolean isTaskInterrupted() -
isTaskFailed
public boolean isTaskFailed() -
setTaskInterrupted
public void setTaskInterrupted(boolean value) -
setTaskFailed
public void setTaskFailed(boolean value) -
exceptionEncountered
public void exceptionEncountered(java.lang.Throwable exception)
-