org.apache.hadoop.hive.ql.exec.spark

Class SparkPlan

java.lang.Object

org.apache.hadoop.hive.ql.exec.spark.SparkPlan

public class SparkPlan
extends Object

Constructor Summary

Constructors

Constructor and Description
SparkPlan()

Method Summary

Methods

Modifier and Type	Method and Description
void	addCachedRDDId(int rddId)
void	addTran(SparkTran tran)
void	connect(SparkTran parent, SparkTran child) Connects the two SparkTrans in the graph.
org.apache.spark.api.java.JavaPairRDD<HiveKey,org.apache.hadoop.io.BytesWritable>	generateGraph()
Set<Integer>	getCachedRDDIds()
List<SparkTran>	getChildren(SparkTran tran)
List<SparkTran>	getParents(SparkTran tran)

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkPlan

public SparkPlan()

Method Detail

generateGraph

public org.apache.spark.api.java.JavaPairRDD<HiveKey,org.apache.hadoop.io.BytesWritable> generateGraph()

addTran

public void addTran(SparkTran tran)

addCachedRDDId

public void addCachedRDDId(int rddId)

getCachedRDDIds

public Set<Integer> getCachedRDDIds()

connect

public void connect(SparkTran parent,
           SparkTran child)

Connects the two SparkTrans in the graph. Does not allow multiple connections between the same pair of SparkTrans.

Parameters:

parent -

child -

getParents

public List<SparkTran> getParents(SparkTran tran)

getChildren

public List<SparkTran> getChildren(SparkTran tran)