Package dev.frostlake.executor.streaming

Class ListRowStream

java.lang.Object

dev.frostlake.executor.streaming.ListRowStream

All Implemented Interfaces:

RowStream

public class ListRowStream
extends Object
implements RowStream

Leaf source that streams rows from an existing list lazily (by index, without copying it).

Constructor Summary

Constructors

Constructor	Description
ListRowStream(List<Row> rows)

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

ListRowStream

public ListRowStream(List<Row> rows)

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