Package org.pentaho.di.trans.streaming.api

Interface StreamSource<R>

All Known Implementing Classes:
BlockingQueueStreamSource
public interface StreamSource<R>
Defines a source of streaming data. A StreamSource implementation is used by BaseStreamStep when loading data from an external stream.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    Signals this stream is no longer in use and can clean up resources.
    io.reactivex.Flowable<R>
    flowable()
    Returns the rows of data as an iterable.
    void
    open()
    Open the source for loading rows.
    void
    pause()
    Causes the stream to stop accepting new input.
    void
    resume()
    Resumes accepting input if paused, otherwise noop.

  • Method Details

    • flowable

      io.reactivex.Flowable<R> flowable()
      Returns the rows of data as an iterable.

    • close

      void close()
      Signals this stream is no longer in use and can clean up resources.

    • pause

      void pause()
      Causes the stream to stop accepting new input.

    • resume

      void resume()
      Resumes accepting input if paused, otherwise noop.

    • open

      void open()
      Open the source for loading rows. Used for initializing resources required to load the stream.