ConsumerExecutor (Storm 2.7.1 API)

java.lang.Object
- org.apache.storm.trident.operation.BaseOperation
- - org.apache.storm.trident.operation.impl.ConsumerExecutor

All Implemented Interfaces:

Serializable, EachOperation, Function, Operation
```
public class ConsumerExecutor
extends BaseOperation
implements Function
```
See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

ConsumerExecutor(Consumer consumer)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`execute(TridentTuple tuple, TridentCollector collector)`	Performs the function logic on an individual tuple and emits 0 or more tuples.

Methods inherited from class org.apache.storm.trident.operation.BaseOperation
cleanup, prepare

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.storm.trident.operation.Operation
cleanup, prepare

- Constructor Detail
  - ConsumerExecutor
```
public ConsumerExecutor(Consumer consumer)
```
- Method Detail
  - execute
```
public void execute(TridentTuple tuple,
                    TridentCollector collector)
```
    Description copied from interface: Function
    
    Performs the function logic on an individual tuple and emits 0 or more tuples.
    
    Specified by:
    
    execute in interface Function
    
    Parameters:
    
    tuple - The incoming tuple
    
    collector - A collector instance that can be used to emit tuples