Package org.rumbledb.runtime.functions.input

Class UnparsedTextLinesFunctionIterator

java.lang.Object

org.rumbledb.runtime.RuntimeIterator

org.rumbledb.runtime.HybridRuntimeIterator

org.rumbledb.runtime.RDDRuntimeIterator

org.rumbledb.runtime.functions.input.UnparsedTextLinesFunctionIterator

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, Serializable, RuntimeIteratorInterface

public class UnparsedTextLinesFunctionIterator
extends RDDRuntimeIterator

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MIN_PARTITIONS

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
UnparsedTextLinesFunctionIterator(List<RuntimeIterator> arguments, RuntimeStaticContext staticContext)

Method Summary

Modifier and Type	Method	Description
org.apache.spark.api.java.JavaRDD<Item>	getRDDAux(DynamicContext context)

Methods inherited from class org.rumbledb.runtime.RDDRuntimeIterator

closeLocal, hasNextLocal, implementsLocal, implementsRDD, nextLocal, openLocal, resetLocal

Methods inherited from class org.rumbledb.runtime.HybridRuntimeIterator

close, dataFrameToRDDOfItems, fallbackToRDDIfDFNotImplemented, getRDD, hasNext, implementsDataFrames, materialize, materializeAtMostOneItemOrNull, materializeExactlyOneItem, materializeFirstItemOrNull, materializeNFirstItems, next, open, reset

Methods inherited from class org.rumbledb.runtime.RuntimeIterator

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

MIN_PARTITIONS

public static final int MIN_PARTITIONS

See Also:

• Constant Field Values

Constructor Details

UnparsedTextLinesFunctionIterator

public UnparsedTextLinesFunctionIterator(List<RuntimeIterator> arguments,
 RuntimeStaticContext staticContext)

Method Details

getRDDAux

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

Overrides:

getRDDAux in class RDDRuntimeIterator