Class Debug
java.lang.Object
org.apache.storm.trident.operation.BaseOperation
org.apache.storm.trident.operation.BaseFilter
org.apache.storm.trident.operation.builtin.Debug
- All Implemented Interfaces:
- Serializable,- EachOperation,- Filter,- Operation
Filter for debugging purposes. The `isKeep()` method simply prints the tuple to `System.out` and returns `true`.
- See Also:
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionbooleanisKeep(TridentTuple tuple) Determines if a tuple should be filtered out of a stream.Methods inherited from class org.apache.storm.trident.operation.BaseOperationcleanup, prepare
- 
Constructor Details- 
Debugpublic Debug()
- 
Debugpublic Debug(boolean useLogger) 
- 
DebugCreates a `Debug` filter with a string identifier.
 
- 
- 
Method Details- 
isKeepDescription copied from interface:FilterDetermines if a tuple should be filtered out of a stream.- Parameters:
- tuple- the tuple being evaluated
- Returns:
- `false` to drop the tuple, `true` to keep the tuple
 
 
-