Package org.rumbledb.runtime

Class AtMostOneItemLocalRuntimeIterator

java.lang.Object

org.rumbledb.runtime.RuntimeIterator

org.rumbledb.runtime.AtMostOneItemLocalRuntimeIterator

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, Serializable, RuntimeIteratorInterface

Direct Known Subclasses:

AbsFunctionIterator, ACosFunctionIterator, AdditiveOperationIterator, AdjustDateTimeToTimezone, AdjustDateToTimezone, AdjustTimeToTimezone, AndOperationIterator, ApplyStatementIterator, ArrayRuntimeIterator, ArraySizeFunctionIterator, ASinFunctionIterator, AssignStatementIterator, ATan2FunctionIterator, ATanFunctionIterator, AtMostOneItemIfRuntimeIterator, AtMostOneItemTypePromotionIterator, AttributeNodeContentRuntimeIterator, AttributeNodeRuntimeIterator, AvgFunctionIterator, BooleanFunctionIterator, BooleanRuntimeIterator, BreakStatementIterator, CardinalityFunctionIterator, CastableIterator, CastIterator, CeilingFunctionIterator, CodepointEqualFunctionIterator, CodepointsToStringFunctionIterator, CommaVariableDeclStatementIterator, CompareFunctionIterator, ComparisonIterator, ComputedAttributeConstructorRuntimeIterator, ComputedElementConstructorRuntimeIterator, ConcatFunctionIterator, ConditionalStatementIterator, ConstantRuntimeIterator, ContainsFunctionIterator, ContextExpressionIterator, ContinueStatementIterator, CosFunctionIterator, CoshFunctionIterator, CountFunctionIterator, CurrentDateFunctionIterator, CurrentDateTimeFunctionIterator, CurrentTimeFunctionIterator, DateTimeFunctionIterator, DayFromDateFunctionIterator, DayFromDateTimeFunctionIterator, DaysFromDurationFunctionIterator, DebugFunctionIterator, DecimalRuntimeIterator, DeepEqualFunctionIterator, DefaultCollationFunctionIterator, DirElemConstructorRuntimeIterator, DocumentNodeConstructorRuntimeIterator, DoubleRuntimeIterator, DynamicItemTypeIterator, EmptyFunctionIterator, EmptySequenceIterator, EndsWithFunctionIterator, ExactlyOneIterator, ExistsFunctionIterator, Exp10FunctionIterator, ExpFunctionIterator, FalseFunctionIterator, FloorFunctionIterator, FormatDateFunctionIterator, FormatDateTimeFunctionIterator, FormatTimeFunctionIterator, FunctionRuntimeIterator, HeadFunctionIterator, HoursFromDateTimeFunctionIterator, HoursFromDurationFunctionIterator, HoursFromTimeFunctionIterator, ImplicitTimezoneIterator, InstanceOfIterator, IntegerRuntimeIterator, IsNullIterator, LastFunctionIterator, Log10FunctionIterator, LogFunctionIterator, LowerCaseFunctionIterator, MatchesFunctionIterator, MaxFunctionIterator, MinFunctionIterator, MinutesFromDateTimeFunctionIterator, MinutesFromDurationFunctionIterator, MinutesFromTimeFunctionIterator, MonthFromDateFunctionIterator, MonthFromDateTimeFunctionIterator, MonthsFromDurationFunctionIterator, MultiplicativeOperationIterator, NamedFunctionRefRuntimeIterator, NodeComparisonRuntimeIterator, NormalizeSpaceFunctionIterator, NormalizeUnicodeFunctionIterator, NotFunctionIterator, NotOperationIterator, NullFunctionIterator, NullRuntimeIterator, NumberFunctionIterator, ObjectAccumulateFunctionIterator, ObjectConstructorRuntimeIterator, ObjectIntersectFunctionIterator, OrOperationIterator, ParseJsonFunctionIterator, PiFunctionIterator, PositionFunctionIterator, PowFunctionIterator, RandomNumberGeneratorIterator, ReplaceFunctionIterator, ResolveURIFunctionIterator, ReturnStatementClauseIterator, RoundFunctionIterator, RoundHalfToEvenFunctionIterator, SecondsFromDateTimeFunctionIterator, SecondsFromDurationFunctionIterator, SecondsFromTimeFunctionIterator, SequenceLookupIterator, SinFunctionIterator, SinhFunctionIterator, SqrtFunctionIterator, StartsWithFunctionIterator, StatementsOnlyIterator, StaticBaseURIFunctionIterator, StringConcatIterator, StringFunctionIterator, StringJoinFunctionIterator, StringLengthFunctionIterator, StringRuntimeIterator, SubstringAfterFunctionIterator, SubstringBeforeFunctionIterator, SubstringFunctionIterator, SumFunctionIterator, SwitchStatementIterator, TanFunctionIterator, TextNodeConstructorRuntimeIterator, TextNodeRuntimeIterator, ThrowErrorIterator, TimeInMillis, TimezoneFromDateFunctionIterator, TimezoneFromDateTimeFunctionIterator, TimezoneFromTimeFunctionIterator, TranslateFunctionIterator, TrueFunctionIterator, TryCatchStatementIterator, TypeSwitchStatementIterator, UnaryOperationIterator, UpperCaseFunctionIterator, VariableDeclStatementIterator, WhileStatementIterator, YearFromDateFunctionIterator, YearFromDateTimeFunctionIterator, YearsFromDurationFunctionIterator, ZeroOrOneIterator

public abstract class AtMostOneItemLocalRuntimeIterator
extends RuntimeIterator

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

Modifier	Constructor	Description
protected	AtMostOneItemLocalRuntimeIterator(List<RuntimeIterator> children, RuntimeStaticContext staticContext)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	getEffectiveBooleanValueOrCheckPosition(DynamicContext dynamicContext, Item position)	This function calculates the effective boolean value of the sequence given by iterator.
org.apache.spark.api.java.JavaRDD<Item>	getRDD(DynamicContext context)
void	materialize(DynamicContext dynamicContext, List<Item> result)	Materialize the items of the iterator into the result list.
Item	materializeAtMostOneItemOrNull(DynamicContext dynamicContext)
Item	materializeExactlyOneItem(DynamicContext dynamicContext)
abstract Item	materializeFirstItemOrNull(DynamicContext context)
void	materializeNFirstItems(DynamicContext dynamicContext, List<Item> result, int n)
Item	next()
void	open(DynamicContext dynamicContext)
void	reset(DynamicContext dynamicContext)

Methods inherited from class org.rumbledb.runtime.RuntimeIterator

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

AtMostOneItemLocalRuntimeIterator

protected AtMostOneItemLocalRuntimeIterator(List<RuntimeIterator> children,
 RuntimeStaticContext staticContext)

Method Details

getRDD

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

Overrides:

getRDD in class RuntimeIterator

materializeFirstItemOrNull

public abstract Item materializeFirstItemOrNull(DynamicContext context)

Overrides:

materializeFirstItemOrNull in class RuntimeIterator

open

public void open(DynamicContext dynamicContext)

Specified by:

open in interface RuntimeIteratorInterface

Overrides:

open in class RuntimeIterator

next

public Item next()

Specified by:

next in interface RuntimeIteratorInterface

Specified by:

next in class RuntimeIterator

reset

public void reset(DynamicContext dynamicContext)

Specified by:

reset in interface RuntimeIteratorInterface

Overrides:

reset in class RuntimeIterator

close

public void close()

Specified by:

close in interface RuntimeIteratorInterface

Overrides:

close in class RuntimeIterator

materializeExactlyOneItem

public Item materializeExactlyOneItem(DynamicContext dynamicContext)
                               throws NoItemException,
MoreThanOneItemException

Overrides:

materializeExactlyOneItem in class RuntimeIterator

Throws:

NoItemException

MoreThanOneItemException

materializeAtMostOneItemOrNull

public Item materializeAtMostOneItemOrNull(DynamicContext dynamicContext)
                                    throws MoreThanOneItemException

Overrides:

materializeAtMostOneItemOrNull in class RuntimeIterator

Throws:

MoreThanOneItemException

materialize

public void materialize(DynamicContext dynamicContext,
 List<Item> result)

Description copied from class: RuntimeIterator

Materialize the items of the iterator into the result list.

Overrides:

materialize in class RuntimeIterator

Parameters:

dynamicContext - the dynamic context

result - the list to materialize the items into. The list is cleared before the materialization.

materializeNFirstItems

public void materializeNFirstItems(DynamicContext dynamicContext,
 List<Item> result,
 int n)

Overrides:

materializeNFirstItems in class RuntimeIterator

getEffectiveBooleanValueOrCheckPosition

public boolean getEffectiveBooleanValueOrCheckPosition(DynamicContext dynamicContext,
 Item position)

Description copied from class: RuntimeIterator

This function calculates the effective boolean value of the sequence given by iterator. Non-empty objects and arrays always return true. Empty sequence returns false. Singleton atomic values are evaluated to their effective boolean value. Multiple atomic values throw an exception. If the sequence is a single numeric item and a non-null position is supplied, then instead it is checked whether the numeric item is equal to the position.

Overrides:

getEffectiveBooleanValueOrCheckPosition in class RuntimeIterator

Parameters:

dynamicContext - the dynamic context

position - the context position, or null if none

Returns:

the effective boolean value.