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

Interface SparkTran<KI extends org.apache.hadoop.io.WritableComparable,VI,KO extends org.apache.hadoop.io.WritableComparable,VO>

All Known Implementing Classes:

MapInput, MapTran, ReduceTran, ShuffleTran

public interface SparkTran<KI extends org.apache.hadoop.io.WritableComparable,VI,KO extends org.apache.hadoop.io.WritableComparable,VO>

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.api.java.JavaPairRDD<KO,VO>	transform(org.apache.spark.api.java.JavaPairRDD<KI,VI> input)

Method Detail

transform

org.apache.spark.api.java.JavaPairRDD<KO,VO> transform(org.apache.spark.api.java.JavaPairRDD<KI,VI> input)