Package org.rumbledb.runtime.cursor

Class MappingLocalCursor<I,O>

java.lang.Object

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

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

Type Parameters:

I - the input type

O - the output type

All Implemented Interfaces:

AutoCloseable, Cursor<O>

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

Cursor that lazily applies a one-to-one transformation to another local plan.

Constructor Summary

Constructors

Constructor	Description
MappingLocalCursor(@NonNull RuntimePlan<I> inputPlan, @NonNull DynamicContext context, @NonNull Function<? super I,? 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

MappingLocalCursor

public MappingLocalCursor(@NonNull
 @NonNull RuntimePlan<I> inputPlan,
 @NonNull
 @NonNull DynamicContext context,
 @NonNull
 @NonNull Function<? super I,? 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>