- String threadName = String.format("%s → %s.", connection.source().name(), FluentIterable.from(connection.sinks()).transform(new Function<Filter, String>() {
-
- @Override
- public String apply(Filter sink) {
- return sink.name();
- }
- }));
+ filterConnections.put(filter, connection);
+ String threadName = String.format("%s → %s", connection.source().name(), filter.name());