javasolrrequest_JavaSolrRequestInfo.getResponseBuilder方法代码示例

import org.apache.solr.request.SolrRequestInfo; //导入方法依赖的package包/类

public JoinQueryWeight(SolrIndexSearcher searcher) {

this.fromSearcher &＃61; searcher;

SolrRequestInfo info &＃61; SolrRequestInfo.getRequestInfo();

if (info !&＃61; null) {

rb &＃61; info.getResponseBuilder();

}

if (fromIndex &＃61;&＃61; null) {

this.fromSearcher &＃61; searcher;

} else {

if (info &＃61;&＃61; null) {

throw new SolrException(SolrException.ErrorCode.BAD_REQUEST, "Cross-core join must have SolrRequestInfo");

}

CoreContainer container &＃61; searcher.getCore().getCoreDescriptor().getCoreContainer();

final SolrCore fromCore &＃61; container.getCore(fromIndex);

if (fromCore &＃61;&＃61; null) {

throw new SolrException(SolrException.ErrorCode.BAD_REQUEST, "Cross-core join: no such core " &＃43; fromIndex);

}

if (info.getReq().getCore() &＃61;&＃61; fromCore) {

// if this is the same core, use the searcher passed in... otherwise we could be warming and

// get an older searcher from the core.

fromSearcher &＃61; searcher;

} else {

// This could block if there is a static warming query with a join in it, and if useColdSearcher is true.

// Deadlock could result if two cores both had useColdSearcher and had joins that used eachother.

// This would be very predictable though (should happen every time if misconfigured)

fromRef &＃61; fromCore.getSearcher(false, true, null);

// be careful not to do anything with this searcher that requires the thread local

// SolrRequestInfo in a manner that requires the core in the request to match

fromSearcher &＃61; fromRef.get();

}

if (fromRef !&＃61; null) {

final RefCounted ref &＃61; fromRef;

info.addCloseHook(new Closeable() {

&＃64;Override

public void close() {

ref.decref();

}

});

}

info.addCloseHook(new Closeable() {

&＃64;Override

public void close() {

fromCore.close();

}

});

}

this.toSearcher &＃61; searcher;

}