Package org.apache.solr.hadoop

Examples of org.apache.solr.hadoop.ForkedZooKeeperInspector


    // Taken from org.apache.solr.hadoop.MapReduceIndexerTool
    private void evaluateShards() {
        if (zkHost != null) {
            assert collection != null;
            ForkedZooKeeperInspector zki = new ForkedZooKeeperInspector();
            try {
                shardUrls = zki.extractShardUrls(zkHost, collection);
            } catch (Exception e) {
                LOG.debug("Cannot extract SolrCloud shard URLs from ZooKeeper", e);
                throw new RuntimeException("Cannot extract SolrCloud shard URLs from ZooKeeper", e);
            }
            assert shardUrls != null;
View Full Code Here

TOP

Related Classes of org.apache.solr.hadoop.ForkedZooKeeperInspector

Copyright © 2018 www.massapicom. 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.