Package org.rumbledb.runtime.misc
Class ComparisonIterator
java.lang.Object
org.rumbledb.runtime.RuntimeIterator
org.rumbledb.runtime.AtMostOneItemLocalRuntimeIterator
org.rumbledb.runtime.misc.ComparisonIterator
- All Implemented Interfaces:
com.esotericsoftware.kryo.KryoSerializable
,Serializable
,RuntimeIteratorInterface
- See Also:
-
Field Summary
Fields inherited from class org.rumbledb.runtime.RuntimeIterator
children, currentDynamicContextForLocalExecution, FLOW_EXCEPTION_MESSAGE, hasNext, isOpen, isSequential, isUpdating, staticContext, staticURI
-
Constructor Summary
ConstructorsConstructorDescriptionComparisonIterator
(RuntimeIterator leftIterator, RuntimeIterator rightIterator, ComparisonExpression.ComparisonOperator comparisonOperator, RuntimeStaticContext staticContext) -
Method Summary
Modifier and TypeMethodDescriptionstatic long
compareItems
(Item left, Item right, ComparisonExpression.ComparisonOperator comparisonOperator, ExceptionMetadata ignoredMetadata) generateNativeQuery
(NativeClauseContext nativeClauseContext) This function generate (if possible) a native spark-sql query that maps the inner working of the iteratorboolean
materializeFirstItemOrNull
(DynamicContext dynamicContext) Methods inherited from class org.rumbledb.runtime.AtMostOneItemLocalRuntimeIterator
close, getEffectiveBooleanValueOrCheckPosition, getRDD, materialize, materializeAtMostOneItemOrNull, materializeExactlyOneItem, materializeNFirstItems, next, open, reset
Methods inherited from class org.rumbledb.runtime.RuntimeIterator
bindToVariableInDynamicContext, canProduceDataFrame, deepCopy, getConfiguration, getDataFrame, getEffectiveBooleanValue, getHighestExecutionMode, getMetadata, getOrCreateDataFrame, getPendingUpdateList, getStaticType, getVariableDependencies, hasNext, isDataFrame, isLocal, isOpen, isRDD, isRDDOrDataFrame, isSequential, isSparkJobNeeded, isUpdating, materialize, materializeAtMostOneItemOrDefault, print, printToStandardError, read, setStaticContext, write
-
Constructor Details
-
ComparisonIterator
public ComparisonIterator(RuntimeIterator leftIterator, RuntimeIterator rightIterator, ComparisonExpression.ComparisonOperator comparisonOperator, RuntimeStaticContext staticContext)
-
-
Method Details
-
getComparisonOperator
-
isValueEquality
public boolean isValueEquality() -
getLeftIterator
-
getRightIterator
-
materializeFirstItemOrNull
- Specified by:
materializeFirstItemOrNull
in classAtMostOneItemLocalRuntimeIterator
-
compareItems
public static long compareItems(Item left, Item right, ComparisonExpression.ComparisonOperator comparisonOperator, ExceptionMetadata ignoredMetadata) -
generateNativeQuery
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 classRuntimeIterator
- 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
-