Package org.rumbledb.runtime.functions.io

Class LocalTextFileFunctionIterator

java.lang.Object

org.rumbledb.runtime.RuntimeIterator

org.rumbledb.runtime.LocalRuntimeIterator

org.rumbledb.runtime.functions.base.LocalFunctionCallIterator

org.rumbledb.runtime.functions.io.LocalTextFileFunctionIterator

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, Serializable, RuntimeIteratorInterface

public class LocalTextFileFunctionIterator
extends LocalFunctionCallIterator

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

Method Summary

Modifier and Type	Method	Description
void	close()
Item	next()
void	open(DynamicContext context)
void	reset(DynamicContext context)

Methods inherited from class org.rumbledb.runtime.RuntimeIterator

bindToVariableInDynamicContext, canProduceDataFrame, deepCopy, generateNativeQuery, getConfiguration, getDataFrame, getEffectiveBooleanValue, getEffectiveBooleanValueOrCheckPosition, getHighestExecutionMode, getMetadata, getOrCreateDataFrame, getPendingUpdateList, getRDD, getStaticType, getVariableDependencies, hasNext, isDataFrame, isLocal, isOpen, isRDD, isRDDOrDataFrame, isSequential, isSparkJobNeeded, isUpdating, materialize, materialize, materializeAtMostOneItemOrDefault, materializeAtMostOneItemOrNull, materializeExactlyOneItem, materializeFirstItemOrNull, materializeNFirstItems, 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

LocalTextFileFunctionIterator

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

Method Details

open

public void open(DynamicContext context)

Specified by:

open in interface RuntimeIteratorInterface

Overrides:

open in class RuntimeIterator

reset

public void reset(DynamicContext context)

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

next

public Item next()

Specified by:

next in interface RuntimeIteratorInterface

Specified by:

next in class RuntimeIterator