Package dev.frostlake.executor.streaming

Class FilterRowStream

java.lang.Object

dev.frostlake.executor.streaming.FilterRowStream

All Implemented Interfaces:

RowStream

public class FilterRowStream
extends Object
implements RowStream

Yields only the rows from its source that satisfy a predicate (the streaming WHERE).

Constructor Summary

Constructors

Constructor	Description
FilterRowStream(RowStream source, RowPredicate predicate)

Method Summary

Modifier and Type	Method	Description
void	close()	Release any resources held by this stream and its sources.
Row	next()	The next row, or null when the stream is exhausted.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FilterRowStream

public FilterRowStream(RowStream source,
 RowPredicate predicate)

Method Details

next

public Row next()

Description copied from interface: RowStream

The next row, or null when the stream is exhausted.

Specified by:

next in interface RowStream

close

public void close()

Description copied from interface: RowStream

Release any resources held by this stream and its sources.

Specified by:

close in interface RowStream