public interface DataProducer
Modifier and Type | Method and Description |
---|---|
bolts.Task<Route> |
addRouteAsync(RouteBuilder builder)
Adds a route to direct where the data will go
|
java.lang.String |
name()
Unique name identifying the data for feedback loops
|
bolts.Task<Route> addRouteAsync(RouteBuilder builder)
builder
- Builder object to construct the routejava.lang.String name()
RouteComponent.filter(Comparison, ComparisonOutput, String...)
,
RouteComponent.map(Function2, String...)