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...)