Class DeleteIndexFromCollectionIterator
java.lang.Object
org.rumbledb.runtime.RuntimeIterator
org.rumbledb.runtime.HybridRuntimeIterator
org.rumbledb.runtime.update.expression.DeleteIndexFromCollectionIterator
- All Implemented Interfaces:
com.esotericsoftware.kryo.KryoSerializable
,Serializable
,RuntimeIteratorInterface
- See Also:
-
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
ConstructorsConstructorDescriptionDeleteIndexFromCollectionIterator
(RuntimeIterator targetIterator, boolean isFirst, boolean isTable, RuntimeStaticContext staticContext) DeleteIndexFromCollectionIterator
(RuntimeIterator targetIterator, RuntimeIterator numDeleteIterator, boolean isFirst, boolean isTable, RuntimeStaticContext staticContext) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
getPendingUpdateList
(DynamicContext context) protected org.apache.spark.api.java.JavaRDD<Item>
getRDDAux
(DynamicContext context) protected boolean
boolean
protected Item
protected void
protected void
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, getStaticType, getVariableDependencies, isDataFrame, isLocal, isOpen, isRDD, isRDDOrDataFrame, isSequential, isSparkJobNeeded, isUpdating, materialize, materializeAtMostOneItemOrDefault, print, printToStandardError, read, setStaticContext, write
-
Constructor Details
-
DeleteIndexFromCollectionIterator
public DeleteIndexFromCollectionIterator(RuntimeIterator targetIterator, boolean isFirst, boolean isTable, RuntimeStaticContext staticContext) -
DeleteIndexFromCollectionIterator
public DeleteIndexFromCollectionIterator(RuntimeIterator targetIterator, RuntimeIterator numDeleteIterator, boolean isFirst, boolean isTable, RuntimeStaticContext staticContext)
-
-
Method Details
-
hasPositionIterator
public boolean hasPositionIterator() -
getRDDAux
- Specified by:
getRDDAux
in classHybridRuntimeIterator
-
openLocal
protected void openLocal()- Specified by:
openLocal
in classHybridRuntimeIterator
-
closeLocal
protected void closeLocal()- Specified by:
closeLocal
in classHybridRuntimeIterator
-
resetLocal
protected void resetLocal()- Specified by:
resetLocal
in classHybridRuntimeIterator
-
hasNextLocal
protected boolean hasNextLocal()- Specified by:
hasNextLocal
in classHybridRuntimeIterator
-
nextLocal
- Specified by:
nextLocal
in classHybridRuntimeIterator
-
getPendingUpdateList
- Overrides:
getPendingUpdateList
in classRuntimeIterator
-