Package org.rumbledb.runtime.scripting.block

Class StatementsWithExprIterator

java.lang.Object

org.rumbledb.runtime.RuntimeIterator

org.rumbledb.runtime.HybridRuntimeIterator

org.rumbledb.runtime.scripting.block.StatementsWithExprIterator

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, Serializable, RuntimeIteratorInterface

public class StatementsWithExprIterator
extends HybridRuntimeIterator

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.rumbledb.runtime.RuntimeIterator

children, currentDynamicContextForLocalExecution, FLOW_EXCEPTION_MESSAGE, hasNext, isOpen, isSequential, isUpdating, staticContext, staticURI

Constructor Summary

Constructors

Constructor	Description
StatementsWithExprIterator(List<RuntimeIterator> statements, RuntimeIterator exprIterator, RuntimeStaticContext staticContext)

Method Summary

Modifier and Type	Method	Description
void	closeLocal()
JSoundDataFrame	getDataFrame(DynamicContext dynamicContext)
PendingUpdateList	getPendingUpdateList(DynamicContext context)
protected org.apache.spark.api.java.JavaRDD<Item>	getRDDAux(DynamicContext dynamicContext)
protected boolean	hasNextLocal()
protected boolean	implementsDataFrames()
boolean	isUpdating()
Item	materializeFirstItemOrNull(DynamicContext context)
Item	nextLocal()
void	openLocal()
void	resetLocal()
void	setNextResult()

Methods inherited from class org.rumbledb.runtime.HybridRuntimeIterator

close, collectRDDwithLimit, dataFrameToRDDOfItems, fallbackToRDDIfDFNotImplemented, getRDD, hasNext, implementsLocal, implementsRDD, materialize, materializeAtMostOneItemOrNull, materializeExactlyOneItem, materializeNFirstItems, next, open, reset

Methods inherited from class org.rumbledb.runtime.RuntimeIterator

bindToVariableInDynamicContext, canProduceDataFrame, deepCopy, generateNativeQuery, getConfiguration, getEffectiveBooleanValue, getEffectiveBooleanValueOrCheckPosition, getHighestExecutionMode, getMetadata, getOrCreateDataFrame, getStaticType, getVariableDependencies, isDataFrame, isLocal, isOpen, isRDD, isRDDOrDataFrame, isSequential, isSparkJobNeeded, materialize, materializeAtMostOneItemOrDefault, print, printToStandardError, read, setStaticContext, write

Methods inherited from class java.lang.Object

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

Constructor Details

StatementsWithExprIterator

public StatementsWithExprIterator(List<RuntimeIterator> statements,
 RuntimeIterator exprIterator,
 RuntimeStaticContext staticContext)

Method Details

materializeFirstItemOrNull

public Item materializeFirstItemOrNull(DynamicContext context)

Overrides:

materializeFirstItemOrNull in class HybridRuntimeIterator

getRDDAux

protected org.apache.spark.api.java.JavaRDD<Item> getRDDAux(DynamicContext dynamicContext)

Specified by:

getRDDAux in class HybridRuntimeIterator

setNextResult

public void setNextResult()

openLocal

public void openLocal()

Specified by:

openLocal in class HybridRuntimeIterator

closeLocal

public void closeLocal()

Specified by:

closeLocal in class HybridRuntimeIterator

resetLocal

public void resetLocal()

Specified by:

resetLocal in class HybridRuntimeIterator

nextLocal

public Item nextLocal()

Specified by:

nextLocal in class HybridRuntimeIterator

hasNextLocal

protected boolean hasNextLocal()

Specified by:

hasNextLocal in class HybridRuntimeIterator

implementsDataFrames

protected boolean implementsDataFrames()

Overrides:

implementsDataFrames in class HybridRuntimeIterator

getDataFrame

public JSoundDataFrame getDataFrame(DynamicContext dynamicContext)

Overrides:

getDataFrame in class RuntimeIterator

isUpdating

public boolean isUpdating()

Overrides:

isUpdating in class RuntimeIterator

getPendingUpdateList

public PendingUpdateList getPendingUpdateList(DynamicContext context)

Overrides:

getPendingUpdateList in class RuntimeIterator