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 Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
isKeep
(TridentTuple tuple) Determines if a tuple should be filtered out of a stream.Methods inherited from class org.apache.storm.trident.operation.BaseOperation
cleanup, prepare
-
Constructor Details
-
Debug
public Debug() -
Debug
public Debug(boolean useLogger) -
Debug
Creates a `Debug` filter with a string identifier.
-
-
Method Details
-
isKeep
Description copied from interface:Filter
Determines 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
-