Package org.rumbledb.runtime.update.expression

Class InsertIndexIntoCollectionIterator

java.lang.Object

org.rumbledb.runtime.RuntimeIterator

org.rumbledb.runtime.HybridRuntimeIterator

org.rumbledb.runtime.update.expression.InsertIndexIntoCollectionIterator

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, Serializable, RuntimeIteratorInterface

public class InsertIndexIntoCollectionIterator
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
InsertIndexIntoCollectionIterator(RuntimeIterator targetIterator, RuntimeIterator contentIterator, boolean isTable, boolean isFirst, boolean isLast, RuntimeStaticContext staticContext)
InsertIndexIntoCollectionIterator(RuntimeIterator targetIterator, RuntimeIterator contentIterator, RuntimeIterator posIterator, boolean isTable, boolean isFirst, boolean isLast, RuntimeStaticContext staticContext)

Method Summary

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

Methods inherited from class org.rumbledb.runtime.HybridRuntimeIterator

close, collectRDDwithLimit, 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, 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

InsertIndexIntoCollectionIterator

public InsertIndexIntoCollectionIterator(RuntimeIterator targetIterator,
 RuntimeIterator contentIterator,
 RuntimeIterator posIterator,
 boolean isTable,
 boolean isFirst,
 boolean isLast,
 RuntimeStaticContext staticContext)

InsertIndexIntoCollectionIterator

public InsertIndexIntoCollectionIterator(RuntimeIterator targetIterator,
 RuntimeIterator contentIterator,
 boolean isTable,
 boolean isFirst,
 boolean isLast,
 RuntimeStaticContext staticContext)

Method Details

hasPositionIterator

public boolean hasPositionIterator()

getRDDAux

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

Specified by:

getRDDAux in class HybridRuntimeIterator

openLocal

protected void openLocal()

Specified by:

openLocal in class HybridRuntimeIterator

closeLocal

protected void closeLocal()

Specified by:

closeLocal in class HybridRuntimeIterator

resetLocal

protected void resetLocal()

Specified by:

resetLocal in class HybridRuntimeIterator

hasNextLocal

protected boolean hasNextLocal()

Specified by:

hasNextLocal in class HybridRuntimeIterator

nextLocal

protected Item nextLocal()

Specified by:

nextLocal in class HybridRuntimeIterator

getPendingUpdateList

public PendingUpdateList getPendingUpdateList(DynamicContext context)

Overrides:

getPendingUpdateList in class RuntimeIterator