Class Supervision


  • public class Supervision
    extends java.lang.Object
    • Constructor Detail

      • Supervision

        public Supervision()
    • Method Detail

      • stop

        public static Supervision.Stop$ stop()
        Java API: The stream will be completed with failure if application code for processing an element throws an exception.
      • resume

        public static Supervision.Resume$ resume()
        Java API: The element is dropped and the stream continues if application code for processing an element throws an exception.
      • restart

        public static Supervision.Restart$ restart()
        Java API: The element is dropped and the stream continues after restarting the operator if application code for processing an element throws an exception. Restarting an operator means that any accumulated state is cleared. This is typically performed by creating a new instance of the operator.
      • stoppingDecider

        public static scala.Function1<java.lang.Throwable,​Supervision.Directive> stoppingDecider()
        Scala API: Decider that returns Stop for all exceptions.
      • getStoppingDecider

        public static Function<java.lang.Throwable,​Supervision.Directive> getStoppingDecider()
        Java API: Decider function that returns stop() for all exceptions.
      • resumingDecider

        public static scala.Function1<java.lang.Throwable,​Supervision.Directive> resumingDecider()
        Scala API: Decider that returns Resume for all exceptions.
      • restartingDecider

        public static scala.Function1<java.lang.Throwable,​Supervision.Directive> restartingDecider()
        Scala API: Decider that returns Restart for all exceptions.