Examples of ZooKeeperImpl


Examples of org.lilyproject.util.zookeeper.ZooKeeperImpl

    @Override
    public ResultToSolrMapper createMapper(String indexName) throws IndexerConfException {
        String zookeeperConnectString = params.get(LResultToSolrMapper.ZOOKEEPER_KEY);
        String repositoryName = params.get(LResultToSolrMapper.REPO_KEY);
        ZooKeeperImpl zk = null;
        LilyClient lilyClient = null;
        LRepository lRepository;
        try {
            zk = new ZooKeeperImpl(zookeeperConnectString, 30000);
            lilyClient = new LilyClient(zk);
            if (repositoryName == null) {
                lRepository = lilyClient.getDefaultRepository();
            } else {
                lRepository = lilyClient.getRepository(repositoryName);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.