Package org.rumbledb.runtime.functions.input

Class XmlFilesFunctionIterator

java.lang.Object

org.rumbledb.runtime.RuntimeIterator

org.rumbledb.runtime.HybridRuntimeIterator

org.rumbledb.runtime.RDDRuntimeIterator

org.rumbledb.runtime.functions.input.XmlFilesFunctionIterator

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, Serializable, RuntimeIteratorInterface

public class XmlFilesFunctionIterator
extends RDDRuntimeIterator

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
XmlFilesFunctionIterator(List<RuntimeIterator> arguments, RuntimeStaticContext staticContext)

Method Summary

Modifier and Type	Method	Description
org.apache.spark.api.java.JavaRDD<Item>	getRDDAux(DynamicContext context)

Methods inherited from class org.rumbledb.runtime.RDDRuntimeIterator

closeLocal, hasNextLocal, implementsLocal, implementsRDD, nextLocal, openLocal, resetLocal

Methods inherited from class org.rumbledb.runtime.HybridRuntimeIterator

close, dataFrameToRDDOfItems, fallbackToRDDIfDFNotImplemented, getRDD, hasNext, implementsDataFrames, 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

XmlFilesFunctionIterator

public XmlFilesFunctionIterator(List<RuntimeIterator> arguments,
 RuntimeStaticContext staticContext)

Method Details

getRDDAux

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

Overrides:

getRDDAux in class RDDRuntimeIterator