package com.cloudera.flume.master.availability;
import java.util.Collections;
import java.util.List;
import com.cloudera.util.consistenthash.ConsistentHash;
int failovers;
this.failovers = failovers;
}
ConsistentHash<String> bins = new ConsistentHash<String>(150, Collections
.<String> emptyList());
@Override
bins.addBin(collector);
}
@Override
bins.removeBin(collector);
}
@Override
return bins.getNUniqueBinsFor(agent, failovers);
}
}