Package org.rumbledb.context

Class VariableValues

java.lang.Object

org.rumbledb.context.VariableValues

All Implemented Interfaces:

com.esotericsoftware.kryo.KryoSerializable, Serializable

public class VariableValues
extends Object
implements Serializable, com.esotericsoftware.kryo.KryoSerializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
VariableValues()
VariableValues(RumbleRuntimeConfiguration configuration)
VariableValues(VariableValues parent)
VariableValues(VariableValues parent, Map<Name,List<Item>> localVariableValues, Map<Name,org.apache.spark.api.java.JavaRDD<Item>> rddVariableValues, Map<Name,JSoundDataFrame> dataFrameVariableValues, GlobalVariables globalVariables)

Method Summary

Modifier and Type	Method	Description
void	addVariableCount(Name varName, Item count)
void	addVariableValue(Name varName, List<Item> value)
void	addVariableValue(Name varName, org.apache.spark.api.java.JavaRDD<Item> value)
void	addVariableValue(Name varName, JSoundDataFrame value)
void	changeVariableValue(Name varName, List<Item> value)
void	changeVariableValue(Name varName, org.apache.spark.api.java.JavaRDD<Item> value)
void	changeVariableValue(Name varName, JSoundDataFrame value)
boolean	contains(Name varName)
boolean	containsLocally(VariableValues variableValues, Name varName)
Set<Name>	getDataFrameVariableNames()
JSoundDataFrame	getDataFrameVariableValue(Name varName, ExceptionMetadata metadata)
Item	getLast()
Set<Name>	getLocalVariableNames()
List<Item>	getLocalVariableValue(Name varName, ExceptionMetadata metadata)
Item	getPosition()
Set<Name>	getRDDVariableNames()
org.apache.spark.api.java.JavaRDD<Item>	getRDDVariableValue(Name varName, ExceptionMetadata metadata)
Item	getVariableCount(Name varName, ExceptionMetadata metadata)
void	importModuleValues(VariableValues moduleValues)
boolean	isDataFrame(Name varName, ExceptionMetadata metadata)
boolean	isParallelAccessAllowed()
boolean	isRDD(Name varName, ExceptionMetadata metadata)
void	read(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input)
void	removeAllVariables()
void	removeVariable(Name varName)
void	setBindingsFromTuple(sparksoniq.jsoniq.tuple.FlworTuple tuple, ExceptionMetadata metadata)
void	setLast(long last)
void	setParallelAccess(boolean b)
void	setPosition(long position)
String	toString()
void	write(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Output output)

Methods inherited from class java.lang.Object

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

Constructor Details

VariableValues

public VariableValues()

VariableValues

public VariableValues(RumbleRuntimeConfiguration configuration)

VariableValues

public VariableValues(VariableValues parent)

VariableValues

public VariableValues(VariableValues parent,
 Map<Name,List<Item>> localVariableValues,
 Map<Name,org.apache.spark.api.java.JavaRDD<Item>> rddVariableValues,
 Map<Name,JSoundDataFrame> dataFrameVariableValues,
 GlobalVariables globalVariables)

Method Details

setBindingsFromTuple

public void setBindingsFromTuple(sparksoniq.jsoniq.tuple.FlworTuple tuple,
 ExceptionMetadata metadata)

getLocalVariableNames

public Set<Name> getLocalVariableNames()

getRDDVariableNames

public Set<Name> getRDDVariableNames()

getDataFrameVariableNames

public Set<Name> getDataFrameVariableNames()

isParallelAccessAllowed

public boolean isParallelAccessAllowed()

setParallelAccess

public void setParallelAccess(boolean b)

contains

public boolean contains(Name varName)

isRDD

public boolean isRDD(Name varName,
 ExceptionMetadata metadata)

isDataFrame

public boolean isDataFrame(Name varName,
 ExceptionMetadata metadata)

addVariableValue

public void addVariableValue(Name varName,
 List<Item> value)

addVariableValue

public void addVariableValue(Name varName,
 org.apache.spark.api.java.JavaRDD<Item> value)

addVariableValue

public void addVariableValue(Name varName,
 JSoundDataFrame value)

addVariableCount

public void addVariableCount(Name varName,
 Item count)

getLocalVariableValue

public List<Item> getLocalVariableValue(Name varName,
 ExceptionMetadata metadata)

getRDDVariableValue

public org.apache.spark.api.java.JavaRDD<Item> getRDDVariableValue(Name varName,
 ExceptionMetadata metadata)

getDataFrameVariableValue

public JSoundDataFrame getDataFrameVariableValue(Name varName,
 ExceptionMetadata metadata)

getVariableCount

public Item getVariableCount(Name varName,
 ExceptionMetadata metadata)

removeVariable

public void removeVariable(Name varName)

removeAllVariables

public void removeAllVariables()

write

public void write(com.esotericsoftware.kryo.Kryo kryo,
 com.esotericsoftware.kryo.io.Output output)

Specified by:

write in interface com.esotericsoftware.kryo.KryoSerializable

read

public void read(com.esotericsoftware.kryo.Kryo kryo,
 com.esotericsoftware.kryo.io.Input input)

Specified by:

read in interface com.esotericsoftware.kryo.KryoSerializable

getPosition

public Item getPosition()

setPosition

public void setPosition(long position)

getLast

public Item getLast()

setLast

public void setLast(long last)

toString

public String toString()

Overrides:

toString in class Object

importModuleValues

public void importModuleValues(VariableValues moduleValues)

containsLocally

public boolean containsLocally(VariableValues variableValues,
 Name varName)

changeVariableValue

public void changeVariableValue(Name varName,
 List<Item> value)

changeVariableValue

public void changeVariableValue(Name varName,
 org.apache.spark.api.java.JavaRDD<Item> value)

changeVariableValue

public void changeVariableValue(Name varName,
 JSoundDataFrame value)