Package org.rumbledb.runtime.dataframe

Interface RuntimeDataFrameFactory<T>

Type Parameters:

T - the logical runtime value represented by each DataFrame row

All Superinterfaces:

Serializable

All Known Implementing Classes:

ItemRuntimeDataFrameFactory

public interface RuntimeDataFrameFactory<T>
extends Serializable

Creates a typed runtime DataFrame from the logical values stored in an RDD.

Method Summary

Modifier and Type	Method	Description
RuntimeDataFrame<T>	fromList(List<T> values, DynamicContext context, RuntimeStaticContext staticContext)
RuntimeDataFrame<T>	fromRDD(org.apache.spark.api.java.JavaRDD<T> rdd, DynamicContext context, RuntimeStaticContext staticContext)

Method Details

fromList

RuntimeDataFrame<T> fromList(List<T> values,
 DynamicContext context,
 RuntimeStaticContext staticContext)

fromRDD

RuntimeDataFrame<T> fromRDD(org.apache.spark.api.java.JavaRDD<T> rdd,
 DynamicContext context,
 RuntimeStaticContext staticContext)