001 package biz.hammurapi.dataflow; 002 003 004 public class MountingMixer extends AbstractMixer { 005 006 private JoinPredicate predicate; 007 private String name; 008 private String separator; 009 010 public MountingMixer(String name, JoinPredicate predicate, String separator) { 011 this.predicate = predicate; 012 this.name = name; 013 this.separator = separator; 014 } 015 016 protected void join(InputEntry[] inputs, String activatorName, DataSink sink) { 017 if (predicate.toBeJoined(inputs, activatorName)) { 018 sink.addData(mountInputs(inputs, separator)); 019 } 020 } 021 022 public String getName() { 023 return name; 024 } 025 026 }