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
- 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
ConstructorsModifierConstructorDescriptionprotected
DataFrameRuntimeIterator
(List<RuntimeIterator> children, RuntimeStaticContext staticContext) -
Method Summary
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
-
Constructor Details
-
DataFrameRuntimeIterator
protected DataFrameRuntimeIterator(List<RuntimeIterator> children, RuntimeStaticContext staticContext)
-
-
Method Details
-
implementsDataFrames
protected boolean implementsDataFrames()- Overrides:
implementsDataFrames
in classHybridRuntimeIterator
-