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 © 2016 The Apache Software Foundation. All rights reserved.