Package org.rumbledb.runtime.functions.object

Class ObjectProjectFunctionIterator

java.lang.Object

org.rumbledb.runtime.RuntimeIterator

org.rumbledb.runtime.HybridRuntimeIterator

org.rumbledb.runtime.functions.object.ObjectProjectFunctionIterator

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, Serializable, RuntimeIteratorInterface

public class ObjectProjectFunctionIterator
extends HybridRuntimeIterator

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

Method Summary

Modifier and Type	Method	Description
protected void	closeLocal()
JSoundDataFrame	getDataFrame(DynamicContext context)
org.apache.spark.api.java.JavaRDD<Item>	getRDDAux(DynamicContext context)
protected boolean	hasNextLocal()
boolean	implementsDataFrames()
Item	nextLocal()
void	openLocal()
protected void	resetLocal()
void	setNextResult()

Methods inherited from class org.rumbledb.runtime.HybridRuntimeIterator

close, collectRDDwithLimit, dataFrameToRDDOfItems, fallbackToRDDIfDFNotImplemented, getRDD, hasNext, implementsLocal, implementsRDD, materialize, materializeAtMostOneItemOrNull, materializeExactlyOneItem, materializeFirstItemOrNull, materializeNFirstItems, next, open, reset

Methods inherited from class org.rumbledb.runtime.RuntimeIterator

bindToVariableInDynamicContext, canProduceDataFrame, deepCopy, generateNativeQuery, getConfiguration, 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

ObjectProjectFunctionIterator

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

Method Details

openLocal

public void openLocal()

Specified by:

openLocal in class HybridRuntimeIterator

nextLocal

public Item nextLocal()

Specified by:

nextLocal in class HybridRuntimeIterator

setNextResult

public void setNextResult()

hasNextLocal

protected boolean hasNextLocal()

Specified by:

hasNextLocal in class HybridRuntimeIterator

resetLocal

protected void resetLocal()

Specified by:

resetLocal in class HybridRuntimeIterator

closeLocal

protected void closeLocal()

Specified by:

closeLocal in class HybridRuntimeIterator

getRDDAux

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

Specified by:

getRDDAux in class HybridRuntimeIterator

implementsDataFrames

public boolean implementsDataFrames()

Overrides:

implementsDataFrames in class HybridRuntimeIterator

getDataFrame

public JSoundDataFrame getDataFrame(DynamicContext context)

Overrides:

getDataFrame in class RuntimeIterator