public interface SparkTran<KI extends org.apache.hadoop.io.WritableComparable,VI,KO extends org.apache.hadoop.io.WritableComparable,VO>
Modifier and Type | Method and Description |
---|---|
String |
getName() |
Boolean |
isCacheEnable() |
void |
setName(String name) |
org.apache.spark.api.java.JavaPairRDD<KO,VO> |
transform(org.apache.spark.api.java.JavaPairRDD<KI,VI> input) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.