Package dev.frostlake.executor.streaming

Class ProjectRowStream

java.lang.Object

dev.frostlake.executor.streaming.ProjectRowStream

All Implemented Interfaces:

RowStream

public class ProjectRowStream
extends Object
implements RowStream

Applies a per-row transform (the streaming projection) to its source.

Constructor Summary

Constructors

Constructor	Description
ProjectRowStream(RowStream source, RowMapper mapper)

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

ProjectRowStream

public ProjectRowStream(RowStream source,
 RowMapper mapper)

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