Package io.deephaven.stream

Interface StreamFailureConsumer

All Known Subinterfaces:
KafkaRecordConsumer, StreamConsumer
All Known Implementing Classes:
StreamToBlinkTableAdapter
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface StreamFailureConsumer
An interface for accepting failures from an incoming stream in order to propagate them to downstream tables.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    acceptFailure(@NotNull Throwable cause)
    Report an error while processing the stream.

  • Method Details

    • acceptFailure

      void acceptFailure(@NotNull @NotNull Throwable cause)
      Report an error while processing the stream.
      Parameters:
      cause - the cause of the error