| 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 LTable<K,V> | LTable. filter(SPredicate<Pair<K,V>> predicate)Filter the rows of the table using the supplied predicate. | 
| default LCollection<S> | LCollection. filter(SPredicate<S> predicate)Filter the collection using the supplied predicate. | 
| default LTable<K,V> | LTable. filterByKey(SPredicate<K> predicate)Filter the rows of the table using the supplied predicate applied to the key part of each record. | 
| default LTable<K,V> | LTable. filterByValue(SPredicate<V> predicate)Filter the rows of the table using the supplied predicate applied to the value part of each record. | 
| default LTable<K,V> | LTable. incrementIf(Enum<?> counter,
           SPredicate<Pair<K,V>> condition)Increment a counter for every element satisfying the conditional predicate supplied. | 
| default LCollection<S> | LCollection. incrementIf(Enum<?> counter,
           SPredicate<S> condition)Increment a counter for every element satisfying the conditional predicate supplied. | 
| default LTable<K,V> | LTable. incrementIf(String counterGroup,
           String counterName,
           SPredicate<Pair<K,V>> condition)Increment a counter for every element satisfying the conditional predicate supplied. | 
| default LCollection<S> | LCollection. incrementIf(String counterGroup,
           String counterName,
           SPredicate<S> condition)Increment a counter for every element satisfying the conditional predicate supplied. | 
Copyright © 2017 The Apache Software Foundation. All rights reserved.