8.跟我学solr---UpdateRequestProcessor具体解释

qwe3223678qwe

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>　　
{
　　@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);
　　}
　　
}