Searched defs:rb (Results 1 - 25 of 29) sorted by relevance

12

/lucene-3.6.0/solr/core/src/java/org/apache/solr/search/grouping/distributed/
H A DShardRequestFactory.java34 * @param rb The response builder
37 ShardRequest[] constructRequest(ResponseBuilder rb); argument
H A DShardResponseProcessor.java32 * fields in the specified rb.
34 * @param rb The ResponseBuilder to put the merge result into
37 void process(ResponseBuilder rb, ShardRequest shardRequest); argument
/lucene-3.6.0/solr/core/src/java/org/apache/solr/search/grouping/distributed/requestfactory/
H A DSearchGroupsRequestFactory.java39 public ShardRequest[] constructRequest(ResponseBuilder rb) { argument
41 GroupingSpecification groupingSpecification = rb.getGroupingSpec();
48 sreq.params = new ModifiableSolrParams(rb.req.getParams());
56 if(rb.shards_start > -1) {
58 sreq.params.set(CommonParams.START,rb.shards_start);
66 if(rb.shards_rows > -1) {
68 sreq.params.set(CommonParams.ROWS,rb.shards_rows);
70 sreq.params.set(CommonParams.ROWS, rb.getSortSpec().getOffset() + rb.getSortSpec().getCount());
77 if ( (rb
[all...]
H A DStoredFieldsShardRequestFactory.java42 public ShardRequest[] constructRequest(ResponseBuilder rb) { argument
44 for (TopGroups<String> topGroups : rb.mergedTopGroups.values()) {
50 for (QueryCommandResult queryCommandResult : rb.mergedQueryCommandResults.values()) {
55 SchemaField uniqueField = rb.req.getSchema().getUniqueKeyField();
62 sreq.params.add( rb.req.getParams());
H A DTopGroupsShardRequestFactory.java52 public ShardRequest[] constructRequest(ResponseBuilder rb) { argument
54 boolean containsGroupByQuery = rb.getGroupingSpec().getQueries().length > 0;
56 if ((rb.getQueryCommand().getFlags() & SolrIndexSearcher.GET_DOCSET) != 0 || containsGroupByQuery) {
58 return createRequestForAllShards(rb);
61 return createRequestForSpecificShards(rb);
65 private ShardRequest[] createRequestForSpecificShards(ResponseBuilder rb) { argument
68 for (String command : rb.searchGroupToShards.keySet()) {
69 Map<SearchGroup<String>, Set<String>> shards = rb.searchGroupToShards.get(command);
75 return createRequest(rb, uniqueShards.toArray(new String[uniqueShards.size()]));
78 private ShardRequest[] createRequestForAllShards(ResponseBuilder rb) { argument
82 createRequest(ResponseBuilder rb, String[] shards) argument
[all...]
/lucene-3.6.0/solr/core/src/java/org/apache/solr/handler/component/
H A DShardHandler.java22 public abstract void checkDistributed(ResponseBuilder rb); argument
H A DMoreLikeThisComponent.java45 public void prepare(ResponseBuilder rb) throws IOException argument
51 public void process(ResponseBuilder rb) throws IOException argument
53 SolrParams p = rb.req.getParams();
55 SolrIndexSearcher searcher = rb.req.getSearcher();
57 NamedList<DocList> sim = getMoreLikeThese( rb, searcher,
58 rb.getResults().docList, rb.getFieldFlags() );
61 rb.rsp.add( "moreLikeThis", sim );
65 NamedList<DocList> getMoreLikeThese( ResponseBuilder rb, SolrIndexSearcher searcher, argument
67 SolrParams p = rb
[all...]
H A DDebugComponent.java42 public void prepare(ResponseBuilder rb) throws IOException argument
49 public void process(ResponseBuilder rb) throws IOException argument
51 if( rb.isDebug() ) {
52 NamedList stdinfo = SolrPluginUtils.doStandardDebug( rb.req,
53 rb.getQueryString(), rb.getQuery(), rb.getResults().docList);
55 NamedList info = rb.getDebugInfo();
57 rb.setDebugInfo( stdinfo );
64 if (rb
86 modifyRequest(ResponseBuilder rb, SearchComponent who, ShardRequest sreq) argument
99 handleResponses(ResponseBuilder rb, ShardRequest sreq) argument
105 finishStage(ResponseBuilder rb) argument
[all...]
H A DHighlightComponent.java60 public void prepare(ResponseBuilder rb) throws IOException { argument
61 SolrParams params = rb.req.getParams();
62 rb.doHighlights = highlighter.isHighlightingEnabled(params);
63 if(rb.doHighlights){
67 QParser parser = QParser.getParser(hlq, null, rb.req);
68 rb.setHighlightQuery(parser.getHighlightQuery());
95 public void process(ResponseBuilder rb) throws IOException { argument
96 if (rb.doHighlights) {
97 SolrQueryRequest req = rb.req;
102 if (rb
145 modifyRequest(ResponseBuilder rb, SearchComponent who, ShardRequest sreq) argument
159 handleResponses(ResponseBuilder rb, ShardRequest sreq) argument
163 finishStage(ResponseBuilder rb) argument
[all...]
H A DHttpShardHandler.java185 public void checkDistributed(ResponseBuilder rb) { argument
186 SolrQueryRequest req = rb.req;
191 rb.shards_rows = Integer.parseInt(shards_rows);
195 rb.shards_start = Integer.parseInt(shards_start);
H A DSearchComponent.java41 * @param rb The {@link org.apache.solr.handler.component.ResponseBuilder}
44 public abstract void prepare(ResponseBuilder rb) throws IOException; argument
48 * @param rb The {@link ResponseBuilder}
51 public abstract void process(ResponseBuilder rb) throws IOException; argument
57 public int distributedProcess(ResponseBuilder rb) throws IOException { argument
62 public void modifyRequest(ResponseBuilder rb, SearchComponent who, ShardRequest sreq) { argument
66 public void handleResponses(ResponseBuilder rb, ShardRequest sreq) { argument
72 public void finishStage(ResponseBuilder rb) { argument
H A DQueryComponent.java74 public void prepare(ResponseBuilder rb) throws IOException argument
77 SolrQueryRequest req = rb.req;
82 SolrQueryResponse rsp = rb.rsp;
90 rb.setFieldFlags( fieldFlags );
96 String queryString = rb.getQueryString();
100 rb.setQueryString(queryString);
104 QParser parser = QParser.getParser(rb.getQueryString(), defType, req);
110 rb.setQuery( q );
111 rb.setSortSpec( parser.getSort(true) );
112 rb
203 process(ResponseBuilder rb) argument
404 doFieldSortValues(ResponseBuilder rb, SolrIndexSearcher searcher) argument
487 doPrefetch(ResponseBuilder rb) argument
499 distributedProcess(ResponseBuilder rb) argument
507 groupedDistributedProcess(ResponseBuilder rb) argument
541 regularDistributedProcess(ResponseBuilder rb) argument
562 handleResponses(ResponseBuilder rb, ShardRequest sreq) argument
570 handleGroupedResponses(ResponseBuilder rb, ShardRequest sreq) argument
585 handleRegularResponses(ResponseBuilder rb, ShardRequest sreq) argument
596 finishStage(ResponseBuilder rb) argument
611 groupedFinishStage(final ResponseBuilder rb) argument
645 regularFinishStage(ResponseBuilder rb) argument
659 createDistributedIdf(ResponseBuilder rb) argument
663 createMainQuery(ResponseBuilder rb) argument
709 mergeIds(ResponseBuilder rb, ShardRequest sreq) argument
825 createRetrieveDocs(ResponseBuilder rb) argument
888 returnFields(ResponseBuilder rb, ShardRequest sreq) argument
[all...]
H A DStatsComponent.java55 public void prepare(ResponseBuilder rb) throws IOException { argument
56 if (rb.req.getParams().getBool(StatsParams.STATS,false)) {
57 rb.setNeedDocSet( true );
58 rb.doStats = true;
63 public void process(ResponseBuilder rb) throws IOException { argument
64 if (rb.doStats) {
65 SolrParams params = rb.req.getParams();
66 SimpleStats s = new SimpleStats(rb.req,
67 rb.getResults().docSet,
71 rb
76 distributedProcess(ResponseBuilder rb) argument
81 modifyRequest(ResponseBuilder rb, SearchComponent who, ShardRequest sreq) argument
102 handleResponses(ResponseBuilder rb, ShardRequest sreq) argument
123 finishStage(ResponseBuilder rb) argument
177 parse(SolrParams params, ResponseBuilder rb) argument
[all...]
H A DTermsComponent.java66 public void prepare(ResponseBuilder rb) throws IOException { argument
67 SolrParams params = rb.req.getParams();
69 rb.doTerms = true;
79 rb.shards = lst.toArray(new String[lst.size()]);
84 public void process(ResponseBuilder rb) throws IOException { argument
85 SolrParams params = rb.req.getParams();
91 rb.rsp.add("terms", terms);
113 FieldType ft = raw ? null : rb.req.getSchema().getFieldTypeNoEx(field);
124 TermEnum termEnum = rb.req.getSearcher().getReader().terms(lowerTerm); //this will be positioned ready to go
213 public int distributedProcess(ResponseBuilder rb) throw argument
236 handleResponses(ResponseBuilder rb, ShardRequest sreq) argument
249 finishStage(ResponseBuilder rb) argument
[all...]
H A DQueryElevationComponent.java319 public void prepare(ResponseBuilder rb) throws IOException argument
321 SolrQueryRequest req = rb.req;
332 Query query = rb.getQuery();
333 String qstr = rb.getQueryString();
353 rb.setQuery(booster.include);
363 rb.setQuery( newq );
369 SortSpec sortSpec = rb.getSortSpec();
399 if( rb.isDebug() ) {
413 rb.addDebugInfo( "queryBoosting", dbg );
418 public void process(ResponseBuilder rb) throw argument
[all...]
/lucene-3.6.0/solr/core/src/java/org/apache/solr/search/grouping/distributed/responseprocessor/
H A DSearchGroupShardResponseProcessor.java42 public void process(ResponseBuilder rb, ShardRequest shardRequest) { argument
43 SortSpec ss = rb.getSortSpec();
44 Sort groupSort = rb.getGroupingSpec().getGroupSort();
45 String[] fields = rb.getGroupingSpec().getFields();
52 if (!rb.searchGroupToShards.containsKey(field)) {
53 rb.searchGroupToShards.put(field, new HashMap<SearchGroup<String>, Set<String>>());
57 SearchGroupsResultTransformer serializer = new SearchGroupsResultTransformer(rb.req.getSearcher());
85 rb.totalHitCount = hitCountDuringFirstPhase;
86 rb.firstPhaseElapsedTime = maxElapsedTime;
94 rb
[all...]
H A DStoredFieldsShardResponseProcessor.java38 public void process(ResponseBuilder rb, ShardRequest shardRequest) { argument
39 boolean returnScores = (rb.getFieldFlags() & SolrIndexSearcher.GET_SCORES) != 0;
42 String uniqueIdFieldName = rb.req.getSchema().getUniqueKeyField().getName();
46 ShardDoc shardDoc = rb.resultIds.get(id);
52 rb.retrievedDocuments.put(id, doc);
H A DTopGroupsShardResponseProcessor.java51 public void process(ResponseBuilder rb, ShardRequest shardRequest) { argument
52 Sort groupSort = rb.getGroupingSpec().getGroupSort();
53 String[] fields = rb.getGroupingSpec().getFields();
54 String[] queries = rb.getGroupingSpec().getQueries();
55 Sort sortWithinGroup = rb.getGroupingSpec().getSortWithinGroup();
59 if (rb.getGroupingSpec().getResponseFormat() == Grouping.Format.simple || rb.getGroupingSpec().isMain()) {
62 groupOffsetDefault = rb.getGroupingSpec().getGroupOffset();
64 int docsPerGroupDefault = rb.getGroupingSpec().getGroupLimit();
76 TopGroupsResultTransformer serializer = new TopGroupsResultTransformer(rb);
[all...]
/lucene-3.6.0/solr/core/src/java/org/apache/solr/search/grouping/endresulttransformer/
H A DEndResultTransformer.java37 * @param rb The response builder containing the response used to render the result and the grouping specification
40 void transform(Map<String, ?> result, ResponseBuilder rb, SolrDocumentSource solrDocumentSource); argument
H A DGroupedEndResultTransformer.java50 public void transform(Map<String, ?> result, ResponseBuilder rb, SolrDocumentSource solrDocumentSource) { argument
58 command.add("matches", rb.totalHitCount);
80 docList.setStart(rb.getGroupingSpec().getGroupOffset());
98 docList.setStart(rb.getGroupingSpec().getGroupOffset());
106 rb.rsp.add("grouped", commands);
H A DMainEndResultTransformer.java38 public void transform(Map<String, ?> result, ResponseBuilder rb, SolrDocumentSource solrDocumentSource) { argument
39 Object value = result.get(rb.getGroupingSpec().getFields()[0]);
44 docList.setStart(rb.getGroupingSpec().getOffset());
45 docList.setNumFound(rb.totalHitCount);
59 rb.rsp.add("response", docList);
H A DSimpleEndResultTransformer.java39 public void transform(Map<String, ?> result, ResponseBuilder rb, SolrDocumentSource solrDocumentSource) { argument
47 command.add("matches", rb.totalHitCount);
52 docList.setStart(rb.getGroupingSpec().getOffset());
72 rb.rsp.add("grouped", commands);
/lucene-3.6.0/solr/core/src/java/org/apache/solr/request/
H A DSolrRequestInfo.java33 protected ResponseBuilder rb; field in class:SolrRequestInfo
85 return rb;
88 public void setResponseBuilder(ResponseBuilder rb) { argument
89 this.rb = rb;
/lucene-3.6.0/solr/core/src/java/org/apache/solr/search/grouping/distributed/shardresultserializer/
H A DTopGroupsResultTransformer.java51 private final ResponseBuilder rb; field in class:TopGroupsResultTransformer
53 public TopGroupsResultTransformer(ResponseBuilder rb) { argument
54 this.rb = rb;
66 SchemaField groupField = rb.req.getSearcher().getSchema().getField(fieldCommand.getKey());
169 SchemaField uniqueField = rb.req.getSearcher().getSchema().getUniqueKeyField();
195 Sort sortWithinGroup = rb.getGroupingSpec().getSortWithinGroup();
196 SchemaField field = sortWithinGroup.getSort()[j].getField() != null ? rb.req.getSearcher().getSchema().getFieldOrNull(sortWithinGroup.getSort()[j].getField()) : null;
219 if (rb.getGroupingSpec().isNeedScore()) {
225 SchemaField uniqueField = rb
[all...]
/lucene-3.6.0/solr/contrib/clustering/src/java/org/apache/solr/handler/clustering/
H A DClusteringComponent.java70 public void prepare(ResponseBuilder rb) throws IOException { argument
71 SolrParams params = rb.req.getParams();
78 public void process(ResponseBuilder rb) throws IOException { argument
79 SolrParams params = rb.req.getParams();
83 String name = getClusteringEngineName(rb);
86 SearchClusteringEngine engine = getSearchClusteringEngine(rb);
88 DocListAndSet results = rb.getResults();
90 SolrDocumentList solrDocList = engine.getSolrDocumentList(results.docList, rb.req, docIds);
91 Object clusters = engine.cluster(rb.getQuery(), solrDocList, docIds, rb
117 getSearchClusteringEngine(ResponseBuilder rb) argument
121 getClusteringEngineName(ResponseBuilder rb) argument
126 modifyRequest(ResponseBuilder rb, SearchComponent who, ShardRequest sreq) argument
157 finishStage(ResponseBuilder rb) argument
[all...]

Completed in 122 milliseconds

12