Package | Description |
---|---|
org.apache.crunch.lambda |
Alternative Crunch API using Java 8 features to allow construction of pipelines using lambda functions and method
references.
|
Modifier and Type | Method and Description |
---|---|
default <K,V> LTable<K,V> |
LCollection.parallelDo(LDoFn<S,Pair<K,V>> fn,
PTableType<K,V> pType)
Transform this LCollection using a Lambda-friendly
LDoFn . |
default <T> LCollection<T> |
LCollection.parallelDo(LDoFn<S,T> fn,
PType<T> pType)
Transform this LCollection using a Lambda-friendly
LDoFn . |
Copyright © 2016 The Apache Software Foundation. All rights reserved.