| Interface | Description |
|---|---|
| RDDConverter<IN,OUT,T extends PhysicalOperator> |
Given an RDD and a PhysicalOperater, and implementation of this class can
convert the RDD to another RDD.
|
| Class | Description |
|---|---|
| BroadcastConverter | |
| CollectedGroupConverter | |
| CounterConverter | |
| DistinctConverter | |
| FilterConverter |
Converter that converts an RDD to a filtered RRD using POFilter
|
| ForEachConverter |
Convert that is able to convert an RRD to another RRD using a POForEach
|
| FRJoinConverter | |
| GlobalRearrangeConverter | |
| IndexedKey |
IndexedKey records the index and key info.
|
| JoinGroupSparkConverter | |
| LimitConverter | |
| LoadConverter |
Converter that loads data via POLoad and converts it to RRD<Tuple>.
|
| LocalRearrangeConverter | |
| MergeCogroupConverter | |
| MergeJoinConverter | |
| PackageConverter | |
| PoissonSampleConverter | |
| RankConverter | |
| ReduceByConverter | |
| SecondaryKeySortUtil |
Provide utility functions which is used by ReducedByConverter and JoinGroupSparkConverter.
|
| SkewedJoinConverter | |
| SortConverter | |
| SparkSampleSortConverter | |
| SplitConverter | |
| StoreConverter |
Converter that takes a POStore and stores it's content.
|
| StreamConverter | |
| UnionConverter |
Copyright © 2007-2017 The Apache Software Foundation