Package org.rumbledb.runtime.xml

Class SlashExprIterator

java.lang.Object

org.rumbledb.runtime.RuntimeIterator

org.rumbledb.runtime.HybridRuntimeIterator

org.rumbledb.runtime.xml.SlashExprIterator

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, Serializable, RuntimeIteratorInterface

public class SlashExprIterator
extends HybridRuntimeIterator

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.rumbledb.runtime.HybridRuntimeIterator

result

Fields inherited from class org.rumbledb.runtime.RuntimeIterator

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

Constructor Summary

Constructors

Constructor	Description
SlashExprIterator(RuntimeIterator sequence, RuntimeIterator stepIterator, RuntimeStaticContext staticContext)

Method Summary

Modifier and Type	Method	Description
void	closeLocal()
org.apache.spark.api.java.JavaRDD<Item>	getRDDAux(DynamicContext dynamicContext)
boolean	hasNextLocal()
Item	nextLocal()
void	openLocal()
void	resetLocal()

Methods inherited from class org.rumbledb.runtime.HybridRuntimeIterator

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

Methods inherited from class org.rumbledb.runtime.RuntimeIterator

bindToVariableInDynamicContext, canProduceDataFrame, deepCopy, generateNativeQuery, getConfiguration, getDataFrame, getEffectiveBooleanValue, getEffectiveBooleanValueOrCheckPosition, getHighestExecutionMode, getMetadata, getOrCreateDataFrame, getPendingUpdateList, getStaticType, getVariableDependencies, isDataFrame, isLocal, isOpen, isRDD, isRDDOrDataFrame, isSequential, isSparkJobNeeded, isUpdating, 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

SlashExprIterator

public SlashExprIterator(RuntimeIterator sequence,
 RuntimeIterator stepIterator,
 RuntimeStaticContext staticContext)

Method Details

getRDDAux

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

Specified by:

getRDDAux in class HybridRuntimeIterator

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

hasNextLocal

public boolean hasNextLocal()

Specified by:

hasNextLocal in class HybridRuntimeIterator

nextLocal

public Item nextLocal()

Specified by:

nextLocal in class HybridRuntimeIterator