|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use FilterFn | |
---|---|
org.apache.crunch | Client-facing API and core abstractions. |
org.apache.crunch.fn | Commonly used functions for manipulating collections. |
org.apache.crunch.impl.dist.collect |
Uses of FilterFn in org.apache.crunch |
---|
Methods in org.apache.crunch with parameters of type FilterFn | |
---|---|
PTable<K,V> |
PTable.filter(FilterFn<Pair<K,V>> filterFn)
Apply the given filter function to this instance and return the resulting PTable . |
PCollection<S> |
PCollection.filter(FilterFn<S> filterFn)
Apply the given filter function to this instance and return the resulting PCollection . |
PTable<K,V> |
PTable.filter(String name,
FilterFn<Pair<K,V>> filterFn)
Apply the given filter function to this instance and return the resulting PTable . |
PCollection<S> |
PCollection.filter(String name,
FilterFn<S> filterFn)
Apply the given filter function to this instance and return the resulting PCollection . |
Uses of FilterFn in org.apache.crunch.fn |
---|
Methods in org.apache.crunch.fn that return FilterFn | ||
---|---|---|
static
|
FilterFns.ACCEPT_ALL()
Accept everything. |
|
static
|
FilterFns.and(FilterFn<S>... fns)
Accept an entry if all of the given filters accept it, using short-circuit evaluation. |
|
static
|
FilterFns.and(FilterFn<S> fn1,
FilterFn<S> fn2)
Accept an entry if all of the given filters accept it, using short-circuit evaluation. |
|
static
|
FilterFns.not(FilterFn<S> fn)
Accept an entry if the given filter does not accept it. |
|
static
|
FilterFns.or(FilterFn<S>... fns)
Accept an entry if at least one of the given filters accept it, using short-circuit evaluation. |
|
static
|
FilterFns.or(FilterFn<S> fn1,
FilterFn<S> fn2)
Accept an entry if at least one of the given filters accept it, using short-circuit evaluation. |
|
static
|
FilterFns.REJECT_ALL()
Reject everything. |
Methods in org.apache.crunch.fn with parameters of type FilterFn | ||
---|---|---|
static
|
FilterFns.and(FilterFn<S>... fns)
Accept an entry if all of the given filters accept it, using short-circuit evaluation. |
|
static
|
FilterFns.and(FilterFn<S> fn1,
FilterFn<S> fn2)
Accept an entry if all of the given filters accept it, using short-circuit evaluation. |
|
static
|
FilterFns.and(FilterFn<S> fn1,
FilterFn<S> fn2)
Accept an entry if all of the given filters accept it, using short-circuit evaluation. |
|
static
|
FilterFns.not(FilterFn<S> fn)
Accept an entry if the given filter does not accept it. |
|
static
|
FilterFns.or(FilterFn<S>... fns)
Accept an entry if at least one of the given filters accept it, using short-circuit evaluation. |
|
static
|
FilterFns.or(FilterFn<S> fn1,
FilterFn<S> fn2)
Accept an entry if at least one of the given filters accept it, using short-circuit evaluation. |
|
static
|
FilterFns.or(FilterFn<S> fn1,
FilterFn<S> fn2)
Accept an entry if at least one of the given filters accept it, using short-circuit evaluation. |
Uses of FilterFn in org.apache.crunch.impl.dist.collect |
---|
Methods in org.apache.crunch.impl.dist.collect with parameters of type FilterFn | |
---|---|
PTable<K,V> |
PTableBase.filter(FilterFn<Pair<K,V>> filterFn)
|
PCollection<S> |
PCollectionImpl.filter(FilterFn<S> filterFn)
|
PTable<K,V> |
PTableBase.filter(String name,
FilterFn<Pair<K,V>> filterFn)
|
PCollection<S> |
PCollectionImpl.filter(String name,
FilterFn<S> filterFn)
|
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |