Package | Description |
---|---|
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 |
Modifier and Type | Method and Description |
---|---|
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 . |
Modifier and Type | Method and Description |
---|---|
static <S> FilterFn<S> |
FilterFns.ACCEPT_ALL()
Accept everything.
|
static <S> FilterFn<S> |
FilterFns.and(FilterFn<S>... fns)
Accept an entry if all of the given filters accept it, using short-circuit evaluation.
|
static <S> FilterFn<S> |
FilterFns.and(FilterFn<S> fn1,
FilterFn<S> fn2)
Accept an entry if all of the given filters accept it, using short-circuit evaluation.
|
static <S> FilterFn<S> |
FilterFns.not(FilterFn<S> fn)
Accept an entry if the given filter does not accept it.
|
static <S> FilterFn<S> |
FilterFns.or(FilterFn<S>... fns)
Accept an entry if at least one of the given filters accept it, using short-circuit evaluation.
|
static <S> FilterFn<S> |
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 <S> FilterFn<S> |
FilterFns.REJECT_ALL()
Reject everything.
|
Modifier and Type | Method and Description |
---|---|
static <S> FilterFn<S> |
FilterFns.and(FilterFn<S>... fns)
Accept an entry if all of the given filters accept it, using short-circuit evaluation.
|
static <S> FilterFn<S> |
FilterFns.and(FilterFn<S> fn1,
FilterFn<S> fn2)
Accept an entry if all of the given filters accept it, using short-circuit evaluation.
|
static <S> FilterFn<S> |
FilterFns.and(FilterFn<S> fn1,
FilterFn<S> fn2)
Accept an entry if all of the given filters accept it, using short-circuit evaluation.
|
static <S> FilterFn<S> |
FilterFns.not(FilterFn<S> fn)
Accept an entry if the given filter does not accept it.
|
static <S> FilterFn<S> |
FilterFns.or(FilterFn<S>... fns)
Accept an entry if at least one of the given filters accept it, using short-circuit evaluation.
|
static <S> FilterFn<S> |
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 <S> FilterFn<S> |
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.
|
Modifier and Type | Method and Description |
---|---|
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) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.