8.跟我學solr---UpdateRequestProcessor具體解釋
阿新 • • 發佈:2017-05-26
condition pos 進行 upd new factor 代碼 ren public
假設配置文件裏沒有指定一個"default"。solr會默認選擇LogUpdateProcessorFactory 和 RunUpdateProcessorFactory作為默認的handler。
通過這個配置,當你發起一個/update/processortest請求的時候,就會選擇JsonUpdateRequestHandler,然後該Handler會默認選擇一個名為mychain的UpdateChain,假設不知道JsonUpdateRequestHandler是什麽東西,能夠參考之前的章節。http://blog.csdn.net/jaynol/article/details/24959373
配置例如以下:
簡單介紹
java web開發的同學應該非常熟悉,在開發中常常會使用filter來處理請求中的一些切面需求。
solr也提供類似的一種鏈式結構的handler來滿足在加入數據索引請求的時候。通過切片的形式,添加一個handler來對請求進行加工。
配置在SORL_HOME\collection1\conf\solrconfig.xml文件裏。配置方式例如以下:
<updateRequestProcessorChain name="mychain" default="true"> <processor class="solr.CustomUpdateRequestProcessorFactory" > <lst name="name"> <str name="n1">x1</str> <str name="n2">x2</str> </lst> </processor> <processor class="solr.LogUpdateProcessorFactory" /> <processor class="solr.RunUpdateProcessorFactory" /> </updateRequestProcessorChain>
怎樣選擇所配置的UpdateChain
1.通過在url中傳參數,比如http://localhost:8983/solr/update/xml?update.chain=mychain
2.在SolrRequestHandler配置中,指定相應的UpdateChain,在SORL_HOME\collection1\conf\solrconfig.xml文件裏。配置例如以下:
<!-- referencing it in an update handler --> <requestHandler name="/update/processortest" class="solr.JsonUpdateRequestHandler" > <lst name="defaults"> <str name="update.chain">mychain</str> </lst> </requestHandler>
一個簡單的UpdateChain樣例
樣例的需求是,新增“cat”字段,僅僅有當“popularity”的值大於5的時候才幹新增。
代碼例如以下:
package my.solr; import java.io.IOException; import org.apache.solr.common.SolrInputDocument; import org.apache.solr.request.SolrQueryRequest; import org.apache.solr.response.SolrQueryResponse; import org.apache.solr.update.AddUpdateCommand; import org.apache.solr.update.processor.UpdateRequestProcessor; import org.apache.solr.update.processor.UpdateRequestProcessorFactory; public class ConditionalCopyProcessorFactory extends UpdateRequestProcessorFactory { @Override public UpdateRequestProcessor getInstance(SolrQueryRequest req, SolrQueryResponse rsp, UpdateRequestProcessor next) { return new ConditionalCopyProcessor(next); } } class ConditionalCopyProcessor extends UpdateRequestProcessor { public ConditionalCopyProcessor( UpdateRequestProcessor next) { super( next ); } @Override public void processAdd(AddUpdateCommand cmd) throws IOException { SolrInputDocument doc = cmd.getSolrInputDocument(); Object v = doc.getFieldValue( "popularity" ); if( v != null ) { int pop = Integer.parseInt( v.toString() ); if( pop > 5 ) { doc.addField( "cat", "popular" ); } } // pass it up the chain super.processAdd(cmd); } }
<updateRequestProcessorChain name="mychain" default="true"> <processor class="my.solr.ConditionalCopyProcessorFactory" /> <processor class="solr.LogUpdateProcessorFactory" /> <processor class="solr.RunUpdateProcessorFactory" /> </updateRequestProcessorChain>
8.跟我學solr---UpdateRequestProcessor具體解釋