public class MapTran extends CacheTran<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable,HiveKey,org.apache.hadoop.io.BytesWritable>
Constructor and Description |
---|
MapTran() |
MapTran(boolean cache,
String name) |
Modifier and Type | Method and Description |
---|---|
org.apache.spark.api.java.JavaPairRDD<HiveKey,org.apache.hadoop.io.BytesWritable> |
doTransform(org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable> input) |
void |
setMapFunction(HiveMapFunction mapFunc) |
getName, isCacheEnable, transform
public MapTran()
public MapTran(boolean cache, String name)
public org.apache.spark.api.java.JavaPairRDD<HiveKey,org.apache.hadoop.io.BytesWritable> doTransform(org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable> input)
doTransform
in class CacheTran<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable,HiveKey,org.apache.hadoop.io.BytesWritable>
public void setMapFunction(HiveMapFunction mapFunc)
Copyright © 2022 The Apache Software Foundation. All rights reserved.