Package org.rumbledb.runtime.navigation

Class PredicateIterator

java.lang.Object

org.rumbledb.runtime.RuntimeIterator

org.rumbledb.runtime.HybridRuntimeIterator

org.rumbledb.runtime.navigation.PredicateIterator

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, Serializable, RuntimeIteratorInterface

public class PredicateIterator
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
PredicateIterator(RuntimeIterator sequence, RuntimeIterator filterExpression, RuntimeStaticContext staticContext)

Method Summary

Modifier and Type	Method	Description
protected void	closeLocal()
NativeClauseContext	generateNativeQuery(NativeClauseContext nativeClauseContext)	This function generate (if possible) a native spark-sql query that maps the inner working of the iterator
JSoundDataFrame	getDataFrame(DynamicContext context)
org.apache.spark.api.java.JavaRDD<Item>	getRDDAux(DynamicContext dynamicContext)
Map<Name,DynamicContext.VariableDependency>	getVariableDependencies()
protected boolean	hasNextLocal()
boolean	implementsDataFrames()
protected Item	nextLocal()
protected void	openLocal()
RuntimeIterator	predicateIterator()
protected void	resetLocal()
RuntimeIterator	sequenceIterator()

Methods inherited from class org.rumbledb.runtime.HybridRuntimeIterator

close, 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, getConfiguration, getEffectiveBooleanValue, getEffectiveBooleanValueOrCheckPosition, getHighestExecutionMode, getMetadata, getOrCreateDataFrame, getPendingUpdateList, getStaticType, 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

PredicateIterator

public PredicateIterator(RuntimeIterator sequence,
 RuntimeIterator filterExpression,
 RuntimeStaticContext staticContext)

Method Details

sequenceIterator

public RuntimeIterator sequenceIterator()

predicateIterator

public RuntimeIterator predicateIterator()

nextLocal

protected Item nextLocal()

Specified by:

nextLocal in class HybridRuntimeIterator

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

openLocal

protected void openLocal()

Specified by:

openLocal in class HybridRuntimeIterator

getRDDAux

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

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

getVariableDependencies

public Map<Name,DynamicContext.VariableDependency> getVariableDependencies()

Overrides:

getVariableDependencies in class RuntimeIterator

generateNativeQuery

public NativeClauseContext generateNativeQuery(NativeClauseContext nativeClauseContext)

Description copied from class: RuntimeIterator

This function generate (if possible) a native spark-sql query that maps the inner working of the iterator

Overrides:

generateNativeQuery in class RuntimeIterator

Parameters:

nativeClauseContext - context information to generate the native query

Returns:

a native clause context with the spark-sql native query to get an equivalent result of the iterator, or [NativeClauseContext.NoNativeQuery] if it is not possible