This project has retired. For details please refer to its Attic page.

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

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)