Package | Description |
---|---|
org.kepler | |
org.kepler.ddp | |
org.kepler.hadoop.execution | |
org.kepler.provenance | |
org.kepler.spark.stub | |
org.kepler.stratosphere.stub | |
ptolemy.actor |
Executable entities.
|
ptolemy.actor.gui |
Ptolemy GUI components for actors and configurations.
|
ptolemy.actor.lib |
Polymorphic actor classes.
|
ptolemy.actor.lib.hoc |
Higher Order Component Classes.
|
ptolemy.actor.process |
Process oriented actor classes.
|
ptolemy.domains.de.lib.test |
The ptolemy.domains.de.lib.test package.
|
ptolemy.domains.modal.kernel |
The ptolemy.domains.modal.kernel package.
|
ptolemy.moml |
Modeling Markup Language classes.
|
ptolemy.vergil |
The Ptolemy II GUI.
|
ptolemy.vergil.actor.lib |
Vergil specific actors.
|
ptolemy.vergil.basic |
Basic GUI classes.
|
Modifier and Type | Method and Description |
---|---|
Manager |
ExecutionEngine.runModel(CompositeActor model)
run a single model in the current thread
|
Manager |
ExecutionEngine.runModelInThread(CompositeActor model)
run a model in a new thread.
|
Modifier and Type | Method and Description |
---|---|
void |
KeplerConfigurationApplication.executionError(Manager manager,
java.lang.Throwable throwable)
Print a stack trace of the error.
|
void |
ExecutionEngine.executionError(Manager manager,
java.lang.Throwable throwable)
implements executionError in ExecutionListener
|
void |
ExecutionEngine.executionFinished(Manager manager)
implements executionFinished in ExecutionListener
|
void |
ExecutionEngine.managerStateChanged(Manager manager)
implements managerStateChanged in ExecutionListener
|
Modifier and Type | Method and Description |
---|---|
static Manager |
Utilities.createManagerForModel(CompositeActor model,
ExecutionListener listener,
StubBaseActor stubSource,
StubBaseActor stubSink,
boolean runWorkflowLifecyclePerInput,
boolean enablePrintTimeAndMemory)
Create a Manager for a model and optionally start execution.
|
Modifier and Type | Field and Description |
---|---|
protected Manager |
KeplerAppBase._manager
Manager to execute the workflow.
|
Modifier and Type | Method and Description |
---|---|
void |
KeplerAppBase.executionError(Manager manager,
java.lang.Throwable throwable) |
void |
KeplerAppBase.executionFinished(Manager manager) |
void |
KeplerAppBase.managerStateChanged(Manager manager) |
Modifier and Type | Method and Description |
---|---|
void |
ProvenanceRecorder.executionError(Manager manager,
java.lang.Throwable throwable)
Report an execution failure.
|
void |
ProvenanceRecorder.executionFinished(Manager manager)
Report that the current execution has finished and the wrapup
sequence has completed normally.
|
void |
ProvenanceRecorder.managerStateChanged(Manager manager)
Report that the manager has changed state.
|
Modifier and Type | Field and Description |
---|---|
protected Manager |
KeplerPairFlatMapFunction._manager
Manager to execute the workflow.
|
Modifier and Type | Method and Description |
---|---|
void |
KeplerPairFlatMapFunction.executionError(Manager manager,
java.lang.Throwable throwable)
Report workflow execution errors to the log.
|
void |
KeplerPairFlatMapFunction.executionFinished(Manager manager)
Do nothing.
|
void |
KeplerPairFlatMapFunction.managerStateChanged(Manager manager)
Do nothing.
|
Modifier and Type | Method and Description |
---|---|
void |
KeplerCrossStub.executionError(Manager manager,
java.lang.Throwable throwable)
Report workflow execution errors to the log.
|
void |
KeplerCoGroupStub.executionError(Manager manager,
java.lang.Throwable throwable)
Report workflow execution errors to the log.
|
void |
KeplerReduceStub.executionError(Manager manager,
java.lang.Throwable throwable)
Report workflow execution errors to the log.
|
void |
KeplerMatchStub.executionError(Manager manager,
java.lang.Throwable throwable)
Report workflow execution errors to the log.
|
void |
KeplerMapStub.executionError(Manager manager,
java.lang.Throwable throwable)
Report workflow execution errors to the log.
|
void |
KeplerCrossStub.executionFinished(Manager manager)
Do nothing.
|
void |
KeplerCoGroupStub.executionFinished(Manager manager)
Do nothing.
|
void |
KeplerReduceStub.executionFinished(Manager manager)
Do nothing.
|
void |
KeplerMatchStub.executionFinished(Manager manager)
Do nothing.
|
void |
KeplerMapStub.executionFinished(Manager manager)
Do nothing.
|
void |
KeplerCrossStub.managerStateChanged(Manager manager)
Do nothing.
|
void |
KeplerCoGroupStub.managerStateChanged(Manager manager)
Do nothing.
|
void |
KeplerReduceStub.managerStateChanged(Manager manager)
Do nothing.
|
void |
KeplerMatchStub.managerStateChanged(Manager manager)
Do nothing.
|
void |
KeplerMapStub.managerStateChanged(Manager manager)
Do nothing.
|
Modifier and Type | Method and Description |
---|---|
Manager |
Actor.getManager()
Return the Manager, if there is one.
|
Manager |
AtomicActor.getManager()
Return the Manager responsible for execution of this actor,
if there is one.
|
Manager |
CompositeActor.getManager()
Get the manager responsible for execution of this composite actor.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamExecutionListener.executionError(Manager manager,
java.lang.Throwable throwable)
Report an execution failure by printing a message to output
stream specified to the constructor.
|
void |
ExecutionListener.executionError(Manager manager,
java.lang.Throwable throwable)
Report an execution failure.
|
void |
StreamExecutionListener.executionFinished(Manager manager)
Report that the current execution finished by printing a
message to output stream specified to the constructor.
|
void |
ExecutionListener.executionFinished(Manager manager)
Report that the current execution has finished and
the wrapup sequence has completed normally.
|
void |
StreamExecutionListener.managerStateChanged(Manager manager)
Report that the manager has changed state by printing a
message to output stream specified to the constructor.
|
void |
ExecutionListener.managerStateChanged(Manager manager)
Report that the manager has changed state.
|
void |
CompositeActor.setManager(Manager manager)
Set the Manager for execution of this CompositeActor.
|
Modifier and Type | Field and Description |
---|---|
protected Manager |
PtolemyApplet._manager
The manager, created in the init() method.
|
Modifier and Type | Method and Description |
---|---|
void |
PtolemyApplet.executionError(Manager manager,
java.lang.Throwable throwable)
Report that an execute error occurred.
|
void |
ConfigurationApplication.executionError(Manager manager,
java.lang.Throwable throwable)
Reduce the count of executing models by one.
|
void |
PtExecuteApplication.executionError(Manager manager,
java.lang.Throwable throwable)
Display a stack trace because one of the models has an error.
|
void |
ModelFrame.executionError(Manager manager,
java.lang.Throwable throwable)
Report that an execution error has occurred.
|
void |
PtolemyApplet.executionFinished(Manager manager)
Report that execution of the model has finished.
|
void |
ConfigurationApplication.executionFinished(Manager manager)
Reduce the count of executing models by one.
|
void |
ModelFrame.executionFinished(Manager manager)
Report that execution of the model has finished.
|
void |
PtolemyApplet.managerStateChanged(Manager manager)
Report that the manager state has changed.
|
void |
ConfigurationApplication.managerStateChanged(Manager manager)
Do nothing.
|
void |
ModelFrame.managerStateChanged(Manager manager)
Report that a manager state has changed.
|
Modifier and Type | Method and Description |
---|---|
void |
CatchExceptionAttribute.executionError(Manager manager,
java.lang.Throwable throwable)
Do nothing upon execution error.
|
void |
ExceptionManager.executionError(Manager manager,
java.lang.Throwable throwable)
Do nothing upon execution error.
|
void |
CatchExceptionAttribute.executionFinished(Manager manager)
Restart here if restart is desired.
|
void |
ExceptionManager.executionFinished(Manager manager)
Restart here if restart is desired.
|
void |
CatchExceptionAttribute.managerStateChanged(Manager manager)
React to a change of state in the Manager.
|
void |
ExceptionManager.managerStateChanged(Manager manager)
React to a change of state in the Manager.
|
Modifier and Type | Method and Description |
---|---|
void |
ApplyFilterOverArray.executionError(Manager manager,
java.lang.Throwable throwable)
React to the fact that execution has failed by unregistering
as an execution listener and by allowing subsequent executions.
|
void |
ModelReference.executionError(Manager manager,
java.lang.Throwable throwable)
React to the fact that execution has failed by unregistering
as an execution listener and by allowing subsequent executions.
|
void |
ApplyFilterOverArray.executionFinished(Manager manager)
React to the fact that execution is finished by unregistering
as an execution listener and by allowing subsequent executions.
|
void |
ModelReference.executionFinished(Manager manager)
React to the fact that execution is finished by unregistering
as an execution listener and by allowing subsequent executions.
|
void |
ApplyFilterOverArray.managerStateChanged(Manager manager)
Report in debugging statements that the manager state has changed.
|
void |
ModelReference.managerStateChanged(Manager manager)
Report in debugging statements that the manager state has changed.
|
Modifier and Type | Field and Description |
---|---|
protected Manager |
ProcessThread._manager
The Manager of the actor.
|
Modifier and Type | Field and Description |
---|---|
Manager |
Mutate.manager |
Modifier and Type | Method and Description |
---|---|
Manager |
FSMActor.getManager()
Return the Manager responsible for execution of this actor,
if there is one.
|
Modifier and Type | Field and Description |
---|---|
protected Manager |
MoMLSimpleApplication._manager
The manager of this model.
|
Modifier and Type | Method and Description |
---|---|
void |
MoMLSimpleApplication.executionError(Manager manager,
java.lang.Throwable throwable)
Report an execution failure.
|
void |
MoMLSimpleApplication.executionFinished(Manager manager)
Report that the current execution has finished and
the wrapup sequence has completed normally.
|
void |
MoMLSimpleApplication.managerStateChanged(Manager manager)
Report that the manager has changed state.
|
Modifier and Type | Method and Description |
---|---|
void |
TypeAnimatorApplet.managerStateChanged(Manager manager)
React to the fact that the manager state has changed.
|
Modifier and Type | Method and Description |
---|---|
void |
ShowTypes.executionError(Manager manager,
java.lang.Throwable throwable)
Update displayed types.
|
void |
ShowTypes.executionFinished(Manager manager)
Do nothing.
|
void |
ShowTypes.managerStateChanged(Manager manager)
Update displayed types.
|
Modifier and Type | Method and Description |
---|---|
protected Manager |
RunnableGraphController._getManager()
Get the manager for the top-level of the associated model,
if there is one, or create one if there is not.
|
Modifier and Type | Method and Description |
---|---|
void |
RunnableGraphController.executionError(Manager manager,
java.lang.Throwable throwable)
Report that an execution error has occurred.
|
void |
RunnableGraphController.executionFinished(Manager manager)
Report that execution of the model has finished.
|
void |
RunnableGraphController.managerStateChanged(Manager manager)
Report that a manager state has changed.
|