Class Hierarchy
- java.lang.Object
- org.rumbledb.runtime.functions.object.ObjectDescendantClosure (implements org.apache.spark.api.java.function.FlatMapFunction<T,
R>) - org.rumbledb.runtime.functions.object.ObjectIntersectMapClosure (implements org.apache.spark.api.java.function.Function<T1,
R>) - org.rumbledb.runtime.functions.object.ObjectIntersectReduceClosure (implements org.apache.spark.api.java.function.Function2<T1,
T2, R>) - org.rumbledb.runtime.functions.object.ObjectKeysClosure (implements org.apache.spark.api.java.function.FlatMapFunction<T,
R>) - org.rumbledb.runtime.functions.object.ObjectProjectClosure (implements org.apache.spark.api.java.function.FlatMapFunction<T,
R>) - org.rumbledb.runtime.functions.object.ObjectRemoveKeysClosure (implements org.apache.spark.api.java.function.FlatMapFunction<T,
R>) - org.rumbledb.runtime.functions.object.ObjectValuesClosure (implements org.apache.spark.api.java.function.FlatMapFunction<T,
R>) - org.rumbledb.runtime.plan.RuntimePlan<T> (implements java.io.Serializable)
- org.rumbledb.runtime.plan.ItemRuntimePlan
- org.rumbledb.runtime.AbstractAtMostOneItemRuntimePlan (implements org.rumbledb.runtime.plan.AtMostOneLocalRuntimePlan<T>)
- org.rumbledb.runtime.functions.object.ObjectAccumulateFunctionIterator
- org.rumbledb.runtime.functions.object.ObjectIntersectFunctionIterator
- org.rumbledb.runtime.functions.base.LocalFunctionCallIterator (implements org.rumbledb.runtime.plan.LocalRuntimePlan<T>)
- org.rumbledb.runtime.functions.object.ObjectDescendantPairsFunctionIterator
- org.rumbledb.runtime.functions.object.ObjectDescendantFunctionIterator (implements org.rumbledb.runtime.plan.LocalRuntimePlan<T>, org.rumbledb.runtime.plan.RDDRuntimePlan<T>)
- org.rumbledb.runtime.functions.object.ObjectKeysFunctionIterator (implements org.rumbledb.runtime.plan.LocalRuntimePlan<T>, org.rumbledb.runtime.plan.RDDRuntimePlan<T>)
- org.rumbledb.runtime.functions.object.ObjectProjectFunctionIterator (implements org.rumbledb.runtime.plan.DataFrameRuntimePlan<T>, org.rumbledb.runtime.plan.LocalRuntimePlan<T>, org.rumbledb.runtime.plan.RDDRuntimePlan<T>)
- org.rumbledb.runtime.functions.object.ObjectRemoveKeysFunctionIterator (implements org.rumbledb.runtime.plan.DataFrameRuntimePlan<T>, org.rumbledb.runtime.plan.LocalRuntimePlan<T>, org.rumbledb.runtime.plan.RDDRuntimePlan<T>)
- org.rumbledb.runtime.functions.object.ObjectValuesFunctionIterator (implements org.rumbledb.runtime.plan.LocalRuntimePlan<T>, org.rumbledb.runtime.plan.RDDRuntimePlan<T>)
- org.rumbledb.runtime.AbstractAtMostOneItemRuntimePlan (implements org.rumbledb.runtime.plan.AtMostOneLocalRuntimePlan<T>)
- org.rumbledb.runtime.plan.ItemRuntimePlan
- org.rumbledb.runtime.functions.object.ObjectDescendantClosure (implements org.apache.spark.api.java.function.FlatMapFunction<T,