org.apache.crunch.fn

Class SFunctions

java.lang.Object

org.apache.crunch.fn.SFunctions

public final class SFunctions
extends Object

Utility methods for wrapping existing Spark Java API Functions for Crunch compatibility.

Method Summary

Modifier and Type	Method and Description
static <T> SDoubleFlatMapFunction<T>	wrap(org.apache.spark.api.java.function.DoubleFlatMapFunction<T> f)
static <T> SDoubleFunction<T>	wrap(org.apache.spark.api.java.function.DoubleFunction<T> f)
static <T,R> SFlatMapFunction<T,R>	wrap(org.apache.spark.api.java.function.FlatMapFunction<T,R> f)
static <K,V,R> SFlatMapFunction2<K,V,R>	wrap(org.apache.spark.api.java.function.FlatMapFunction2<K,V,R> f)
static <T,R> SFunction<T,R>	wrap(org.apache.spark.api.java.function.Function<T,R> f)
static <K,V,R> SFunction2<K,V,R>	wrap(org.apache.spark.api.java.function.Function2<K,V,R> f)
static <T,K,V> SPairFunction<T,K,V>	wrap(org.apache.spark.api.java.function.PairFunction<T,K,V> f)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

wrap

public static <T,R> SFunction<T,R> wrap(org.apache.spark.api.java.function.Function<T,R> f)

wrap

public static <K,V,R> SFunction2<K,V,R> wrap(org.apache.spark.api.java.function.Function2<K,V,R> f)

wrap

public static <T,K,V> SPairFunction<T,K,V> wrap(org.apache.spark.api.java.function.PairFunction<T,K,V> f)

wrap

public static <T,R> SFlatMapFunction<T,R> wrap(org.apache.spark.api.java.function.FlatMapFunction<T,R> f)

wrap

public static <K,V,R> SFlatMapFunction2<K,V,R> wrap(org.apache.spark.api.java.function.FlatMapFunction2<K,V,R> f)

wrap

public static <T> SDoubleFunction<T> wrap(org.apache.spark.api.java.function.DoubleFunction<T> f)

wrap

public static <T> SDoubleFlatMapFunction<T> wrap(org.apache.spark.api.java.function.DoubleFlatMapFunction<T> f)