Package org.rumbledb.runtime.cursor

Class FlatMappingLocalCursor<I,O>

java.lang.Object

org.rumbledb.runtime.cursor.AbstractLocalCursor<O>

org.rumbledb.runtime.cursor.FlatMappingLocalCursor<I,O>

All Implemented Interfaces:

AutoCloseable, Cursor<O>

public final class FlatMappingLocalCursor<I,O>
extends AbstractLocalCursor<O>

Streams each input value through a zero-or-more mapping.

Constructor Summary

Constructors

Constructor	Description
FlatMappingLocalCursor(@NonNull RuntimePlan<I> inputPlan, @NonNull DynamicContext context, @NonNull Function<? super I,? extends Iterator<? extends O>> mapper, @NonNull ExceptionMetadata metadata)

Method Summary

Modifier and Type	Method	Description
protected void	closeLocal()
protected boolean	hasNextLocal()
protected O	nextLocal()
protected void	openLocal()

Methods inherited from class org.rumbledb.runtime.cursor.AbstractLocalCursor

close, getMetadata, hasNext, invalidState, next

Methods inherited from class java.lang.Object

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

Constructor Details

FlatMappingLocalCursor

public FlatMappingLocalCursor(@NonNull
 @NonNull RuntimePlan<I> inputPlan,
 @NonNull
 @NonNull DynamicContext context,
 @NonNull
 @NonNull Function<? super I,? extends Iterator<? extends O>> mapper,
 @NonNull
 @NonNull ExceptionMetadata metadata)

Method Details

openLocal

protected void openLocal()

Specified by:

openLocal in class AbstractLocalCursor<O>

hasNextLocal

protected boolean hasNextLocal()

Specified by:

hasNextLocal in class AbstractLocalCursor<O>

nextLocal

protected O nextLocal()

Specified by:

nextLocal in class AbstractLocalCursor<O>

closeLocal

protected void closeLocal()

Specified by:

closeLocal in class AbstractLocalCursor<O>