Package org.voltdb.stream.api

Interface Consumer<O>

All Known Subinterfaces:
VoltStreamSink<T>
All Known Implementing Classes:
FileSink, IterableSink, StdoutSink
public interface Consumer<O>
A Consumer is a link between upstream and downstream operator.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    consume(O output)
    This method is invoked by any upstream caller, the caller can emmit any number of events to a consumer.

  • Method Details

    • consume

      void consume(O output)
      This method is invoked by any upstream caller, the caller can emmit any number of events to a consumer.
      Parameters:
      output - event