Package org.rumbledb.runtime.dataframe

Class ItemRuntimeDataFrameFactory

java.lang.Object

org.rumbledb.runtime.dataframe.ItemRuntimeDataFrameFactory

All Implemented Interfaces:

Serializable, RuntimeDataFrameFactory<Item>

public final class ItemRuntimeDataFrameFactory
extends Object
implements RuntimeDataFrameFactory<Item>

Encodes item RDDs as HomogeneousItemDataFrames.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final ItemRuntimeDataFrameFactory	INSTANCE

Method Summary

Modifier and Type	Method	Description
HomogeneousItemDataFrame	fromList(List<Item> items, DynamicContext context, RuntimeStaticContext staticContext)
HomogeneousItemDataFrame	fromPlan(ItemRuntimePlan plan, DynamicContext context)
HomogeneousItemDataFrame	fromRDD(org.apache.spark.api.java.JavaRDD<Item> rdd, DynamicContext context, RuntimeStaticContext staticContext)

Methods inherited from class java.lang.Object

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

Field Details

INSTANCE

public static final ItemRuntimeDataFrameFactory INSTANCE

Method Details

fromList

public HomogeneousItemDataFrame fromList(List<Item> items,
 DynamicContext context,
 RuntimeStaticContext staticContext)

Specified by:

fromList in interface RuntimeDataFrameFactory<Item>

fromRDD

public HomogeneousItemDataFrame fromRDD(org.apache.spark.api.java.JavaRDD<Item> rdd,
 DynamicContext context,
 RuntimeStaticContext staticContext)

Specified by:

fromRDD in interface RuntimeDataFrameFactory<Item>

fromPlan

public HomogeneousItemDataFrame fromPlan(ItemRuntimePlan plan,
 DynamicContext context)