Package org.rumbledb.runtime.misc

Class RangeOperationIterator

java.lang.Object

org.rumbledb.runtime.RuntimeIterator

org.rumbledb.runtime.HybridRuntimeIterator

org.rumbledb.runtime.misc.RangeOperationIterator

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, Serializable, RuntimeIteratorInterface

public class RangeOperationIterator
extends HybridRuntimeIterator

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final int	PARTITION_SIZE

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
RangeOperationIterator(RuntimeIterator leftIterator, RuntimeIterator rightiterator, RuntimeStaticContext staticContext)

Method Summary

Modifier and Type	Method	Description
protected void	closeLocal()
static JSoundDataFrame	createLongInterval(long left, long right)	Creates a dataframe with a sequence of increasing numbers, of type long.
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)
protected org.apache.spark.api.java.JavaRDD<Item>	getRDDAux(DynamicContext context)
boolean	hasNextLocal()
protected boolean	implementsDataFrames()
Boolean	init(DynamicContext context)	Initializes the boundaries of the range.
Item	nextLocal()
void	openLocal()
protected void	resetLocal()

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, 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

Field Details

PARTITION_SIZE

public static final int PARTITION_SIZE

See Also:

• Constant Field Values

Constructor Details

RangeOperationIterator

public RangeOperationIterator(RuntimeIterator leftIterator,
 RuntimeIterator rightiterator,
 RuntimeStaticContext staticContext)

Method Details

hasNextLocal

public boolean hasNextLocal()

Specified by:

hasNextLocal in class HybridRuntimeIterator

nextLocal

public Item nextLocal()

Specified by:

nextLocal in class HybridRuntimeIterator

init

public Boolean init(DynamicContext context)

Initializes the boundaries of the range.

Parameters:

context - the dynamic context.

Returns:

true if the two bounds are defined, false if one of them is the empty sequence.

openLocal

public void openLocal()

Specified by:

openLocal in class HybridRuntimeIterator

getRDDAux

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

Specified by:

getRDDAux in class HybridRuntimeIterator

implementsDataFrames

protected boolean implementsDataFrames()

Overrides:

implementsDataFrames in class HybridRuntimeIterator

getDataFrame

public JSoundDataFrame getDataFrame(DynamicContext context)

Overrides:

getDataFrame in class RuntimeIterator

createLongInterval

public static JSoundDataFrame createLongInterval(long left,
 long right)

Creates a dataframe with a sequence of increasing numbers, of type long.

Parameters:

left - the left bound(inclusive).

right - the right bound (inclusive).

Returns:

closeLocal

protected void closeLocal()

Specified by:

closeLocal in class HybridRuntimeIterator

resetLocal

protected void resetLocal()

Specified by:

resetLocal in class HybridRuntimeIterator

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