Examples of CoreDescriptor


Examples of org.apache.solr.core.CoreDescriptor

      return coreName;
    }
    @Override
    public CoreContainer initialize() {
      CoreContainer container = new CoreContainer(new SolrResourceLoader(SolrResourceLoader.locateInstanceDir()));
      CoreDescriptor dcore = new CoreDescriptor(container, coreName, solrConfig.getResourceLoader().getInstanceDir());
      dcore.setConfigName(solrConfig.getResourceName());
      dcore.setSchemaName(indexSchema.getResourceName());
      SolrCore core = new SolrCore( null, dataDirectory, solrConfig, indexSchema, dcore);
      container.register(coreName, core, false);
      return container;
    }
View Full Code Here

Examples of org.apache.solr.core.CoreDescriptor

   */
  protected boolean handleCreateAction(SolrQueryRequest req, SolrQueryResponse rsp) throws SolrException {
    try {
      SolrParams params = req.getParams();
      String name = params.get(CoreAdminParams.NAME);
      CoreDescriptor dcore = new CoreDescriptor(coreContainer, name, params.get(CoreAdminParams.INSTANCE_DIR));

      //  fillup optional parameters
      String opts = params.get(CoreAdminParams.CONFIG);
      if (opts != null)
        dcore.setConfigName(opts);

      opts = params.get(CoreAdminParams.SCHEMA);
      if (opts != null)
        dcore.setSchemaName(opts);

      opts = params.get(CoreAdminParams.DATA_DIR);
      if (opts != null)
        dcore.setDataDir(opts);

      dcore.setCoreProperties(null);
      SolrCore core = coreContainer.create(dcore);
      coreContainer.register(name, core, false);
      rsp.add("core", core.getName());
      return coreContainer.isPersistent();
    } catch (Exception ex) {
View Full Code Here

Examples of org.apache.solr.core.CoreDescriptor

      return coreName;
    }
    @Override
    public CoreContainer initialize() {
      CoreContainer container = new CoreContainer(new SolrResourceLoader(SolrResourceLoader.locateSolrHome()));
      CoreDescriptor dcore = new CoreDescriptor(container, coreName, solrConfig.getResourceLoader().getInstanceDir());
      dcore.setConfigName(solrConfig.getResourceName());
      dcore.setSchemaName(indexSchema.getResourceName());
      SolrCore core = new SolrCore( null, dataDirectory, solrConfig, indexSchema, dcore);
      container.register(coreName, core, false);
      return container;
    }
View Full Code Here

Examples of org.apache.solr.core.CoreDescriptor

        }
        SolrCore old = null;
        ClassLoader classLoader = updateContextClassLoader();
        SolrCore core;
        try {
            CoreDescriptor coreDescriptor = new CoreDescriptor(server,
                coreName, coreDir.getAbsolutePath());
            core = server.create(coreDescriptor);
            //add the CloseHook
            core.addCloseHook(closeHook);
            // parse ture as third argument to avoid closing the current core for now
View Full Code Here

Examples of org.apache.solr.core.CoreDescriptor

                "EmbeddedSolrServer for IndexReference {}",reference,this.reference);
        }
        if(trackingSolrCore){
            SolrCore core = (SolrCore)service;
            coreName = core.getName();
            CoreDescriptor descriptior = core.getCoreDescriptor();
            if(descriptior == null){ //core not registered with a container!
                context.ungetService(reference);
                return null; //ignore
            } else {
                server = descriptior.getCoreContainer();
            }
        } else {
            server = (CoreContainer)service;
            coreName = this.coreName;
        }
View Full Code Here

Examples of org.apache.solr.core.CoreDescriptor

      LOG.info(String
          .format(
              "Constructed instance information solr.home %s (%s), instance dir %s, conf dir %s, writing index to temporary directory %s, with permdir %s",
              solrHome, solrHome.toUri(), loader.getInstanceDir(), loader.getConfigDir(), dataDir, perm));
      CoreContainer container = new CoreContainer(loader);
      CoreDescriptor descr = new CoreDescriptor(container, "core1", solrHome.toString());
      descr.setDataDir(dataDir);
      descr.setCoreProperties(props);
      core = container.create(descr);
      container.register(core, false);
      solr = new EmbeddedSolrServer(container, "core1");
      batchWriter = new BatchWriter(solr, batchSize, context.getTaskAttemptID().getTaskID(), threadCount, queueSize);
View Full Code Here

Examples of org.apache.solr.core.CoreDescriptor

    private SolrServer solr;

    public SolrConsumerTestCase() throws ParserConfigurationException, IOException, SAXException {
        SolrResourceLoader loader = new SolrResourceLoader("solr");
        CoreContainer container = new CoreContainer(loader);
        CoreDescriptor descriptor = new CoreDescriptor(container, "cname", ".");
        SolrCore core = container.create(descriptor);
        container.register(core.getName(), core, false);
        this.solr = new EmbeddedSolrServer(container, core.getName());
    }
View Full Code Here

Examples of org.apache.solr.core.CoreDescriptor

        if(!coreDir.isDirectory()){
            throw new IllegalArgumentException("The Core Directory '"+
                coreDir+" for the Core '"+coreName+"' does not exist or is not an directory");
        }
        SolrCore core;
        CoreDescriptor coreDescriptor = new CoreDescriptor(server,
            coreName, coreDir.getAbsolutePath());
        core = server.create(coreDescriptor);
        //this will also replace an existing core with the same name
        server.register(coreName, core, false);
        server.persist(); //store the new/updated SolrCore in the solr.xml
View Full Code Here

Examples of org.apache.solr.core.CoreDescriptor

                                 reference.getProperty(Constants.SERVICE_ID));
                context.ungetService(reference);
                return null;
            }
            coreName = core.getName();
            CoreDescriptor descriptor = core.getCoreDescriptor();
            if(descriptor == null){ //core not registered with a container!
                context.ungetService(reference);
                return null; //ignore
            } else {
                server = descriptor.getCoreContainer();
            }
        } else {
            if(service instanceof CoreContainer){
                    server = (CoreContainer)service;
            } else {
View Full Code Here

Examples of org.apache.solr.core.CoreDescriptor

        SolrCore core;
        try {
            //NOTE: this code depends on the fact that the create method of the
            //      CoreContainer is overridden by the SolrServerAdapter
            //      to use the OSGI specific SolrResourceLoader!
            core = server.create(new CoreDescriptor(server,
                coreName, coreDir.getPath()));
            //CloseHook is now appied by the overridden registerCore(..) method
            //of the wrapped CoreContainer!
            //core.addCloseHook(closeHook);
            // parse ture as third argument to avoid closing the current core for now
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.