Class MapFindFunctionIterator
java.lang.Object
org.rumbledb.runtime.RuntimeIterator
org.rumbledb.runtime.HybridRuntimeIterator
org.rumbledb.runtime.functions.maps.MapFindFunctionIterator
- All Implemented Interfaces:
com.esotericsoftware.kryo.KryoSerializable,Serializable,RuntimeIteratorInterface
FO 3.1 map:find($input as item()*, $key as xs:anyAtomicType) as array(*).
- See Also:
-
Field Summary
Fields inherited from class org.rumbledb.runtime.HybridRuntimeIterator
resultFields inherited from class org.rumbledb.runtime.RuntimeIterator
children, currentDynamicContextForLocalExecution, FLOW_EXCEPTION_MESSAGE, hasNext, isOpen, isSequential, isUpdating, staticContext, staticURI -
Constructor Summary
ConstructorsConstructorDescriptionMapFindFunctionIterator(List<RuntimeIterator> arguments, RuntimeStaticContext staticContext) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidgetDataFrame(DynamicContext dynamicContext) org.apache.spark.api.java.JavaRDD<Item>getRDDAux(DynamicContext context) protected booleanprotected booleanprotected Itemprotected voidprotected voidMethods inherited from class org.rumbledb.runtime.HybridRuntimeIterator
close, collectRDDwithLimit, dataFrameToRDDOfItems, fallbackToRDDIfDFNotImplemented, getRDD, hasNext, implementsLocal, implementsRDD, materialize, materializeAtMostOneItemOrNull, materializeExactlyOneItem, materializeFirstItemOrNull, materializeNFirstItems, next, open, resetMethods inherited from class org.rumbledb.runtime.RuntimeIterator
bindToVariableInDynamicContext, canProduceDataFrame, deepCopy, generateNativeQuery, getConfiguration, getEffectiveBooleanValue, getEffectiveBooleanValueOrCheckPosition, getHighestExecutionMode, getMetadata, getOrCreateDataFrame, getPendingUpdateList, getRuntimeStaticContext, getStaticType, getVariableDependencies, isDataFrame, isLocal, isOpen, isRDD, isRDDOrDataFrame, isSequential, isSparkJobNeeded, isUpdating, materialize, materializeAtMostOneItemOrDefault, print, printToStandardError, read, setStaticContext, write
-
Constructor Details
-
MapFindFunctionIterator
-
-
Method Details
-
openLocal
protected void openLocal()- Specified by:
openLocalin classHybridRuntimeIterator
-
hasNextLocal
protected boolean hasNextLocal()- Specified by:
hasNextLocalin classHybridRuntimeIterator
-
nextLocal
- Specified by:
nextLocalin classHybridRuntimeIterator
-
resetLocal
protected void resetLocal()- Specified by:
resetLocalin classHybridRuntimeIterator
-
closeLocal
protected void closeLocal()- Specified by:
closeLocalin classHybridRuntimeIterator
-
getRDDAux
- Specified by:
getRDDAuxin classHybridRuntimeIterator
-
implementsDataFrames
protected boolean implementsDataFrames()- Overrides:
implementsDataFramesin classHybridRuntimeIterator
-
getDataFrame
- Overrides:
getDataFramein classRuntimeIterator
-