Package org.apache.crunch.lambda

Alternative Crunch API using Java 8 features to allow construction of pipelines using lambda functions and method references.

See: Description

Interface Summary

Interface	Description
LCollection<S>	Java 8 friendly version of the PCollection interface, allowing distributed operations to be expressed in terms of lambda expressions and method references, instead of creating a new class implementation for each operation.
LCollectionFactory	Factory for creating LCollection, LTable and LGroupedTable objects from their corresponding PCollection, PTable and PGroupedTable types.
LDoFn<S,T>	A Java lambdas friendly version of the DoFn class.
LDoFnContext<S,T>	Context object for implementing distributed operations in terms of Lambda expressions.
LGroupedTable<K,V>	Java 8 friendly version of the PGroupedTable interface, allowing distributed operations to be expressed in terms of lambda expressions and method references, instead of creating a new class implementation for each operation.
LTable<K,V>	Java 8 friendly version of the PTable interface, allowing distributed operations to be expressed in terms of lambda expressions and method references, instead of creating a new class implementation for each operation.

Class Summary

Class	Description
LAggregator<V,A>	Crunch Aggregator expressed as a composition of functional interface implementations
Lambda	Entry point for the crunch-lambda API.

Package org.apache.crunch.lambda Description

Alternative Crunch API using Java 8 features to allow construction of pipelines using lambda functions and method references. It works by wrapping standards Java PCollection, PTable and PGroupedTable instances into the corresponding LCollection, LTable and classes.

The static class Lambda has methods to create these. Please also see the Javadocs for Lambda for usage examples