This project has retired. For details please refer to its Attic page.

org.apache.crunch
Class FilterFn.AndFn<S>

java.lang.Object
  org.apache.crunch.DoFn<T,T>
      org.apache.crunch.FilterFn<S>
          org.apache.crunch.FilterFn.AndFn<S>

All Implemented Interfaces:

Serializable

Enclosing class:

FilterFn<T>

public static class FilterFn.AndFn<S>
extends FilterFn<S>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.crunch.FilterFn

FilterFn.AndFn<S>, FilterFn.NotFn<S>, FilterFn.OrFn<S>

Constructor Summary

FilterFn.AndFn(FilterFn<S>... fns)

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.

Methods inherited from class org.apache.crunch.FilterFn

and, not, or, process

Methods inherited from class org.apache.crunch.DoFn

cleanup, configure, initialize, setConfigurationForTest, setContext

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FilterFn.AndFn

public FilterFn.AndFn(FilterFn<S>... fns)

Method Detail

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>