Interface RunningInterpreter

    • Method Detail

      • connections

        scala.collection.immutable.Seq<ConnectionSnapshot> connections()
        Each connection between logics in the interpreter
        Returns:
        (undocumented)
      • logics

        scala.collection.immutable.Seq<LogicSnapshot> logics()
        Each of the materialized graph stage logics running inside the interpreter
        Specified by:
        logics in interface InterpreterSnapshot
        Returns:
        (undocumented)
      • runningLogicsCount

        int runningLogicsCount()
        Total number of non-stopped logics in the interpreter
        Returns:
        (undocumented)
      • stoppedLogics

        scala.collection.immutable.Seq<LogicSnapshot> stoppedLogics()
        All logics that has completed and is no longer executing
        Returns:
        (undocumented)