Package org.rumbledb.runtime.typing

Class CastIterator

java.lang.Object

org.rumbledb.runtime.RuntimeIterator

org.rumbledb.runtime.AtMostOneItemLocalRuntimeIterator

org.rumbledb.runtime.typing.CastIterator

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, Serializable, RuntimeIteratorInterface

public class CastIterator
extends AtMostOneItemLocalRuntimeIterator

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.rumbledb.runtime.RuntimeIterator

children, currentDynamicContextForLocalExecution, FLOW_EXCEPTION_MESSAGE, hasNext, isOpen, isSequential, isUpdating, staticContext, staticURI

Constructor Summary

Constructors

Constructor	Description
CastIterator(RuntimeIterator child, SequenceType sequenceType, RuntimeStaticContext staticContext)

Method Summary

Modifier and Type	Method	Description
static Item	castItemToType(Item item, ItemType targetType, ExceptionMetadata metadata)
static boolean	checkDateTimeMinMaxFacets(Item item, ItemType targetType)
static boolean	checkFacetsAnyURI(Item item, ItemType targetType)
static boolean	checkFacetsBase64Binary(Item item, ItemType targetType)
static boolean	checkFacetsBoolean(Item item, ItemType targetType)
static boolean	checkFacetsDate(Item item, ItemType targetType)
static boolean	checkFacetsDateTime(Item item, ItemType targetType)
static boolean	checkFacetsDateTimeStamp(Item item, ItemType targetType)
static boolean	checkFacetsDecimal(Item item, ItemType targetType)
static boolean	checkFacetsDouble(Item item, ItemType targetType)
static boolean	checkFacetsDuration(Item item, ItemType targetType)
static boolean	checkFacetsFloat(Item item, ItemType targetType)
static boolean	checkFacetsHexBinary(Item item, ItemType targetType)
static boolean	checkFacetsInteger(Item item, ItemType targetType)
static boolean	checkFacetsNull(Item item, ItemType targetType)
static boolean	checkFacetsString(Item item, ItemType targetType)
static boolean	checkFacetsTime(Item item, ItemType targetType)
NativeClauseContext	generateNativeQuery(NativeClauseContext nativeClauseContext)	This function generate (if possible) a native spark-sql query that maps the inner working of the iterator
Item	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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CastIterator

public CastIterator(RuntimeIterator child,
 SequenceType sequenceType,
 RuntimeStaticContext staticContext)

Method Details

materializeFirstItemOrNull

public Item materializeFirstItemOrNull(DynamicContext dynamicContext)

Specified by:

materializeFirstItemOrNull in class AtMostOneItemLocalRuntimeIterator

castItemToType

public static Item castItemToType(Item item,
 ItemType targetType,
 ExceptionMetadata metadata)

checkFacetsInteger

public static boolean checkFacetsInteger(Item item,
 ItemType targetType)

checkFacetsNull

public static boolean checkFacetsNull(Item item,
 ItemType targetType)

checkFacetsString

public static boolean checkFacetsString(Item item,
 ItemType targetType)

checkFacetsBoolean

public static boolean checkFacetsBoolean(Item item,
 ItemType targetType)

checkFacetsDouble

public static boolean checkFacetsDouble(Item item,
 ItemType targetType)

checkFacetsFloat

public static boolean checkFacetsFloat(Item item,
 ItemType targetType)

checkFacetsDecimal

public static boolean checkFacetsDecimal(Item item,
 ItemType targetType)

checkFacetsAnyURI

public static boolean checkFacetsAnyURI(Item item,
 ItemType targetType)

checkFacetsBase64Binary

public static boolean checkFacetsBase64Binary(Item item,
 ItemType targetType)

checkFacetsHexBinary

public static boolean checkFacetsHexBinary(Item item,
 ItemType targetType)

checkDateTimeMinMaxFacets

public static boolean checkDateTimeMinMaxFacets(Item item,
 ItemType targetType)

checkFacetsDate

public static boolean checkFacetsDate(Item item,
 ItemType targetType)

checkFacetsTime

public static boolean checkFacetsTime(Item item,
 ItemType targetType)

checkFacetsDateTime

public static boolean checkFacetsDateTime(Item item,
 ItemType targetType)

checkFacetsDateTimeStamp

public static boolean checkFacetsDateTimeStamp(Item item,
 ItemType targetType)

checkFacetsDuration

public static boolean checkFacetsDuration(Item item,
 ItemType targetType)

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