com.cloudera.crunch
Class FilterFn.NotFn<S>

java.lang.Object
  com.cloudera.crunch.DoFn<T,T>
      com.cloudera.crunch.FilterFn<S>
          com.cloudera.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

Nested Class Summary

Nested classes/interfaces inherited from class com.cloudera.crunch.FilterFn

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

Constructor Summary

FilterFn.NotFn(FilterFn<S> base)

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 com.cloudera.crunch.FilterFn

and, not, or, process

Methods inherited from class com.cloudera.crunch.DoFn

cleanup, configure, getConfiguration, getCounter, getCounter, getStatus, getTaskAttemptID, initialize, progress, setConfigurationForTest, setContext, setStatus

Methods inherited from class java.lang.Object

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

Constructor Detail

FilterFn.NotFn

public FilterFn.NotFn(FilterFn<S> base)

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>