SuspendingRuntime

portals.runtime.SuspendingRuntime
See theSuspendingRuntime companion object

Attributes

Companion
object
Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Abstract methods

def canStep(): Boolean

Returns true if the runtime can take another step.

Returns true if the runtime can take another step.

Attributes

def feedAtoms(listOfAtoms: List[EventBatch]): Unit

Feed a listOfAtoms to the runtime.

Feed a listOfAtoms to the runtime.

Distributes the atoms to the corresponding processing units. Can be used to feed back the outputs from Completed steps.

Attributes

def resume(path: Path, shuffles: List[ShuffleBatch[_]]): StepResult

Resume a suspended processor for path and input shuffles.

Resume a suspended processor for path and input shuffles.

Attributes

def step(): StepResult

Take and return the result of a step.

Take and return the result of a step.

Returns Completed if the step processes an atom until completion.

Returns Suspended if the processing was suspended, for example due to a ShuffleTask. A suspended processor will not be able to take another step until it is resume()d. A suspended processor is resumed through the call resume() with the corresponding path and shuffle side-effects.

Attributes

Inherited methods

def launch(application: Application): Unit

Launch an application.

Launch an application.

Attributes

Inherited from:
PortalsRuntime
def shutdown(): Unit

Terminate the runtime.

Terminate the runtime.

Attributes

Inherited from:
PortalsRuntime