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 and Description
void	close() Signals this stream is no longer in use and can clean up resources.
io.reactivex.Observable<R>	observable() 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 Detail

observable

io.reactivex.Observable<R> observable()

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.