Class TrueFilter

All Implemented Interfaces:
Serializable, EachOperation, Filter, Operation

public class TrueFilter extends Object implements Filter
See Also:
  • Constructor Details

    • TrueFilter

      public TrueFilter()
  • Method Details

    • isKeep

      public boolean isKeep(TridentTuple tuple)
      Description copied from interface: Filter
      Determines if a tuple should be filtered out of a stream.
      Specified by:
      isKeep in interface Filter
      tuple - the tuple being evaluated
      `false` to drop the tuple, `true` to keep the tuple
    • prepare

      public void prepare(Map<String,Object> conf, TridentOperationContext context)
      Description copied from interface: Operation
      Called when the `Operation` is first initialized.
      Specified by:
      prepare in interface Operation
      conf - the Storm configuration map
      context - the operation context which provides information such as the number of partitions in the stream, and the current partition index. It also provides methods for registering operation-specific metrics.
      See Also:
    • cleanup

      public void cleanup()
      Description copied from interface: Operation
      When running in local mode, called when the local cluster is being shut down.
      Specified by:
      cleanup in interface Operation