public class MapInput extends Object implements SparkTran<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable>
Constructor and Description |
---|
MapInput(SparkPlan sparkPlan,
org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable> hadoopRDD) |
MapInput(SparkPlan sparkPlan,
org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable> hadoopRDD,
boolean toCache) |
Modifier and Type | Method and Description |
---|---|
String |
getName() |
Boolean |
isCacheEnable() |
void |
setName(String name) |
void |
setToCache(boolean toCache) |
org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable> |
transform(org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable> input) |
public MapInput(SparkPlan sparkPlan, org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable> hadoopRDD)
public MapInput(SparkPlan sparkPlan, org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable> hadoopRDD, boolean toCache)
public void setToCache(boolean toCache)
public org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable> transform(org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable> input)
public String getName()
public Boolean isCacheEnable()
isCacheEnable
in interface SparkTran<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable>
Copyright © 2016 The Apache Software Foundation. All rights reserved.