Package org.rumbledb.runtime

Class DataFrameRuntimeIterator

java.lang.Object

org.rumbledb.runtime.RuntimeIterator

org.rumbledb.runtime.HybridRuntimeIterator

org.rumbledb.runtime.RDDRuntimeIterator

org.rumbledb.runtime.DataFrameRuntimeIterator

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, Serializable, RuntimeIteratorInterface

Direct Known Subclasses:

AvroFileFunctionIterator, CollectionFunctionIterator, CSVFileFunctionIterator, DeltaFileFunctionIterator, DeltaTableFunctionIterator, LibSVMFileFunctionIterator, ParquetFileFunctionIterator, RootFileFunctionIterator, StructuredJsonLinesFunctionIterator

public abstract class DataFrameRuntimeIterator
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

Modifier	Constructor	Description
protected	DataFrameRuntimeIterator(List<RuntimeIterator> children, RuntimeStaticContext staticContext)

Method Summary

Modifier and Type	Method	Description
protected boolean	implementsDataFrames()

Methods inherited from class org.rumbledb.runtime.RDDRuntimeIterator

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

Methods inherited from class org.rumbledb.runtime.HybridRuntimeIterator

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

DataFrameRuntimeIterator

protected DataFrameRuntimeIterator(List<RuntimeIterator> children,
 RuntimeStaticContext staticContext)

Method Details

implementsDataFrames

protected boolean implementsDataFrames()

Overrides:

implementsDataFrames in class HybridRuntimeIterator