public abstract class CacheTran<KI extends org.apache.hadoop.io.WritableComparable,VI,KO extends org.apache.hadoop.io.WritableComparable,VO> extends Object implements SparkTran<KI,VI,KO,VO>
Modifier | Constructor and Description |
---|---|
protected |
CacheTran(boolean cache,
String name,
BaseWork baseWork) |
Modifier and Type | Method and Description |
---|---|
protected abstract org.apache.spark.api.java.JavaPairRDD<KO,VO> |
doTransform(org.apache.spark.api.java.JavaPairRDD<KI,VI> input) |
BaseWork |
getBaseWork() |
String |
getName() |
Boolean |
isCacheEnable() |
org.apache.spark.api.java.JavaPairRDD<KO,VO> |
transform(org.apache.spark.api.java.JavaPairRDD<KI,VI> input) |
protected final String name
public org.apache.spark.api.java.JavaPairRDD<KO,VO> transform(org.apache.spark.api.java.JavaPairRDD<KI,VI> input)
public Boolean isCacheEnable()
protected abstract org.apache.spark.api.java.JavaPairRDD<KO,VO> doTransform(org.apache.spark.api.java.JavaPairRDD<KI,VI> input)
public String getName()
Copyright © 2022 The Apache Software Foundation. All rights reserved.