Package org.apache.storm.trident.operation

Interface Consumer

All Superinterfaces:
Serializable
public interface Consumer extends Serializable
Represents an operation that accepts a single input argument and returns no result. This is similar to the Consumer interface in Java 8.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    accept(TridentTuple input)
    Performs the operation on the input trident tuple.

  • Method Details

    • accept

      void accept(TridentTuple input)
      Performs the operation on the input trident tuple.
      Parameters:
      input - the input trident tuple