SuspendingRuntime

portals.runtime.SuspendingRuntime$
See theSuspendingRuntime companion trait

Attributes

Companion
trait
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Type members

Classlikes

case class Completed(path: Path, outputs: List[EventBatch]) extends StepResult

Complete output from processing an atom to completion.

Complete output from processing an atom to completion.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait StepResult
class Object
trait Matchable
class Any
Show all
sealed trait StepResult

Resulting output produced by taking a step().

Resulting output produced by taking a step().

Attributes

Supertypes
class Object
trait Matchable
class Any
Known subtypes
class Completed
class Suspended
case class Suspended(path: Path, shuffle: List[ShuffleBatch[_]], intermediate: List[EventBatch]) extends StepResult

Suspended processing of path with shuffle side-effects and intermediate output.

Suspended processing of path with shuffle side-effects and intermediate output.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait StepResult
class Object
trait Matchable
class Any
Show all