org.apache.pig.backend.hadoop.executionengine.spark.converter

Interface RDDConverter<IN,OUT,T extends PhysicalOperator>

All Known Implementing Classes:

BroadcastConverter, CollectedGroupConverter, CounterConverter, DistinctConverter, FilterConverter, ForEachConverter, FRJoinConverter, GlobalRearrangeConverter, JoinGroupSparkConverter, LimitConverter, LoadConverter, LocalRearrangeConverter, MergeCogroupConverter, MergeJoinConverter, PackageConverter, PoissonSampleConverter, RankConverter, ReduceByConverter, SkewedJoinConverter, SortConverter, SparkSampleSortConverter, SplitConverter, StoreConverter, StreamConverter, UnionConverter

public interface RDDConverter<IN,OUT,T extends PhysicalOperator>

Given an RDD and a PhysicalOperater, and implementation of this class can convert the RDD to another RDD.

Method Summary

Modifier and Type	Method and Description
<any>	convert(List<<any>> rdd, T physicalOperator)

Method Detail

convert

<any> convert(List<<any>> rdd,
              T physicalOperator)
       throws IOException

Throws:

IOException