Package org.rumbledb.runtime.plan

Class RuntimePlanConversions

java.lang.Object

org.rumbledb.runtime.plan.RuntimePlanConversions

public final class RuntimePlanConversions
extends Object

Stateless conversions between the local, RDD, and DataFrame representations used by runtime plans.

Method Summary

Modifier and Type	Method	Description
static <T> List<T>	collectRDDWithLimit(org.apache.spark.api.java.JavaRDD<T> rdd, int materializationCap, ExceptionMetadata metadata)
static <T> org.apache.spark.api.java.JavaRDD<T>	cursorToRDD(Cursor<T> cursor, int materializationCap, ExceptionMetadata metadata)
static <T> List<T>	materializeCursor(Cursor<T> cursor)
static <T> Cursor<T>	rddToCursor(org.apache.spark.api.java.JavaRDD<T> rdd, int materializationCap, ExceptionMetadata metadata)

Methods inherited from class java.lang.Object

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

Method Details

rddToCursor

public static <T> Cursor<T> rddToCursor(org.apache.spark.api.java.JavaRDD<T> rdd,
 int materializationCap,
 ExceptionMetadata metadata)

collectRDDWithLimit

public static <T> List<T> collectRDDWithLimit(org.apache.spark.api.java.JavaRDD<T> rdd,
 int materializationCap,
 ExceptionMetadata metadata)

cursorToRDD

public static <T>
org.apache.spark.api.java.JavaRDD<T> cursorToRDD(Cursor<T> cursor,
 int materializationCap,
 ExceptionMetadata metadata)

materializeCursor

public static <T> List<T> materializeCursor(Cursor<T> cursor)