Uses of Interface
org.apache.crunch.lambda.fn.SFunction

Packages that use SFunction

Package	Description
org.apache.crunch.lambda	Alternative Crunch API using Java 8 features to allow construction of pipelines using lambda functions and method references.

Uses of SFunction in org.apache.crunch.lambda

Methods in org.apache.crunch.lambda with parameters of type SFunction

Modifier and Type	Method and Description
default <K> LTable<K,S>	LCollection.by(SFunction<S,K> extractFn, PType<K> pType) Key this LCollection by a key extracted from the element to yield a LTable mapping the key to the whole element.
default <A> LTable<K,V>	LGroupedTable.combineValues(SSupplier<A> initialSupplier, SBiFunction<A,V,A> combineFn, SFunction<A,Iterable<V>> outputFn) Combine the value part of the table using the given functions.
default <K,V> LTable<K,V>	LCollection.filterMap(SFunction<S,Optional<Pair<K,V>>> fn, PTableType<K,V> pType) Combination of a filter and map operation by using a function with Optional return type.
default <T> LCollection<T>	LCollection.filterMap(SFunction<S,Optional<T>> fn, PType<T> pType) Combination of a filter and map operation by using a function with Optional return type.
default <K,V> LTable<K,V>	LCollection.flatMap(SFunction<S,java.util.stream.Stream<Pair<K,V>>> fn, PTableType<K,V> pType) Map each element to zero or more output elements using the provided stream-returning function to yield an LTable
default <T> LCollection<T>	LCollection.flatMap(SFunction<S,java.util.stream.Stream<T>> fn, PType<T> pType) Map each element to zero or more output elements using the provided stream-returning function.
default <K,V> LTable<K,V>	LCollection.map(SFunction<S,Pair<K,V>> fn, PTableType<K,V> pType) Map the elements of this collection 1-1 through the supplied function to yield an LTable
default <T> LCollection<T>	LCollection.map(SFunction<S,T> fn, PType<T> pType) Map the elements of this collection 1-1 through the supplied function.
default <T> LTable<T,V>	LTable.mapKeys(SFunction<K,T> fn, PType<T> pType) Transform the keys of this table using the given function
default <T> LTable<K,T>	LGroupedTable.mapValues(SFunction<java.util.stream.Stream<V>,T> fn, PType<T> pType) Map the values in this LGroupedTable using a custom function.
default <T> LTable<K,T>	LTable.mapValues(SFunction<V,T> fn, PType<T> pType) Transform the values of this table using the given function

Constructors in org.apache.crunch.lambda with parameters of type SFunction

Constructor and Description
LAggregator(SSupplier<A> initialSupplier, SBiFunction<A,V,A> combineFn, SFunction<A,Iterable<V>> outputFn)