builder
.<String, String>stream("input")
.flatTransformValues(
- new ValueTransformerSupplier<String, Iterable<String>>()
- {
- @Override
- public ValueTransformer<String, Iterable<String>> get()
- {
- return new DeduplicationTransformer();
- }
- },
+ () -> new DeduplicationTransformer(),
DeduplicationTransformer.STORE)
.to("output");