Class Hierarchy
- java.lang.Object
- org.apache.wayang.spark.compiler.BinaryOperatorAdapter<Type> (implements org.apache.spark.api.java.function.Function2<T1,T2,R>)
- org.apache.wayang.spark.compiler.ExtendedBinaryOperatorAdapter<Type> (implements org.apache.spark.api.java.function.Function2<T1,T2,R>)
- org.apache.wayang.spark.compiler.ExtendedFlatMapFunctionAdapter<InputType,OutputType> (implements org.apache.spark.api.java.function.FlatMapFunction<T,R>)
- org.apache.wayang.spark.compiler.ExtendedFunction<InputType,OutputType> (implements org.apache.spark.api.java.function.Function<T1,R>)
- org.apache.wayang.spark.compiler.ExtendedMapFunctionAdapter<InputType,OutputType> (implements org.apache.spark.api.java.function.Function<T1,R>)
- org.apache.wayang.spark.compiler.ExtendedMapPartitionsFunctionAdapter<InputType,OutputType> (implements org.apache.spark.api.java.function.FlatMapFunction<T,R>)
- org.apache.wayang.spark.compiler.ExtendedPredicateAdapater<Type> (implements org.apache.spark.api.java.function.Function<T1,R>)
- org.apache.wayang.spark.compiler.FlatMapFunctionAdapter<InputType,OutputType> (implements org.apache.spark.api.java.function.FlatMapFunction<T,R>)
- org.apache.wayang.spark.compiler.FunctionCompiler
- org.apache.wayang.spark.compiler.FunctionCompiler.KeyExtractor<T,K> (implements org.apache.wayang.spark.compiler.FunctionCompiler.WayangSparkFunction, org.apache.spark.api.java.function.PairFunction<T,K,V>)
- org.apache.wayang.spark.compiler.FunctionCompiler.Reducer<Type> (implements org.apache.spark.api.java.function.Function2<T1,T2,R>, org.apache.wayang.spark.compiler.FunctionCompiler.WayangSparkFunction)
- org.apache.wayang.spark.compiler.MapFunctionAdapter<InputType,OutputType> (implements org.apache.spark.api.java.function.Function<T1,R>)
- org.apache.wayang.spark.compiler.MapPartitionsFunctionAdapter<InputType,OutputType> (implements org.apache.spark.api.java.function.FlatMapFunction<T,R>)
- org.apache.wayang.spark.compiler.PredicateAdapter<InputType> (implements org.apache.spark.api.java.function.Function<T1,R>)