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    }