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 and Description
void	accept(TridentTuple input) Performs the operation on the input trident tuple.

Method Detail

accept

void accept(TridentTuple input)

Performs the operation on the input trident tuple.

Parameters:

input - the input trident tuple