Package | Description |
---|---|
org.apache.crunch |
Client-facing API and core abstractions.
|
org.apache.crunch.fn |
Commonly used functions for manipulating collections.
|
Modifier and Type | Class and Description |
---|---|
static class |
FilterFn.AndFn<S>
Deprecated.
|
static class |
FilterFn.NotFn<S>
Deprecated.
|
static class |
FilterFn.OrFn<S>
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static <S> FilterFn<S> |
FilterFn.and(FilterFn<S>... fns)
Deprecated.
|
static <S> FilterFn<S> |
FilterFn.not(FilterFn<S> fn)
Deprecated.
|
static <S> FilterFn<S> |
FilterFn.or(FilterFn<S>... fns)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static <S> FilterFn<S> |
FilterFn.and(FilterFn<S>... fns)
Deprecated.
|
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 . |
static <S> FilterFn<S> |
FilterFn.not(FilterFn<S> fn)
Deprecated.
|
static <S> FilterFn<S> |
FilterFn.or(FilterFn<S>... fns)
Deprecated.
|
Constructor and Description |
---|
FilterFn.AndFn(FilterFn<S>... fns)
Deprecated.
|
FilterFn.NotFn(FilterFn<S> base)
Deprecated.
|
FilterFn.OrFn(FilterFn<S>... fns)
Deprecated.
|
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.
|
Copyright © 2013 The Apache Software Foundation. All Rights Reserved.