org.apache.crunch
Class FilterFn.NotFn<S>
java.lang.Object
org.apache.crunch.DoFn<T,T>
org.apache.crunch.FilterFn<S>
org.apache.crunch.FilterFn.NotFn<S>
- All Implemented Interfaces:
- Serializable
- Enclosing class:
- FilterFn<T>
public static class FilterFn.NotFn<S>
- extends FilterFn<S>
- See Also:
- Serialized Form
Method Summary |
boolean |
accept(S input)
If true, emit the given record. |
float |
scaleFactor()
Returns an estimate of how applying this function to a PCollection
will cause it to change in side. |
FilterFn.NotFn
public FilterFn.NotFn(FilterFn<S> base)
accept
public boolean accept(S input)
- Description copied from class:
FilterFn
- If true, emit the given record.
- Specified by:
accept
in class FilterFn<S>
scaleFactor
public float scaleFactor()
- Description copied from class:
DoFn
- Returns an estimate of how applying this function to a
PCollection
will cause it to change in side. The optimizer uses these estimates to
decide where to break up dependent MR jobs into separate Map and Reduce
phases in order to minimize I/O.
Subclasses of DoFn
that will substantially alter the size of the
resulting PCollection
should override this method.
- Overrides:
scaleFactor
in class FilterFn<S>
Copyright © 2012 The Apache Software Foundation. All Rights Reserved.