复制/*   *版权：王安琪   *描述：监视HBase，大数一有数据postPut就向Solr发送，企商汇据架本类要作为触发器添加到HBase   *修改时间：2014-05-27   *修改内容：新增   */  package solrHbase.test;  import java.io.UnsupportedEncodingException;  import ***;  public class SorlIndexCoprocessorObserver extends BaseRegionObserver {      private static final Logger LOG = LoggerFactory             .getLogger(SorlIndexCoprocessorObserver.class);      private static final String solrUrl = "http://192.1.11.108:80/solr/core1";      private static final SolrServer solrServer = new ConcurrentUpdateSolrServer(              solrUrl,构使 10000, 20);      /**       * 建立solr索引       *        * @throws UnsupportedEncodingException       */      @Override      public void postPut(final ObserverContext<RegionCoprocessorEnvironment> e,              final Put put, final WALEdit edit, final boolean writeToWAL)              throws UnsupportedEncodingException {          inputSolr(put);      }      public void inputSolr(Put put) {          try {              solrServer.add(TestSolrMain.getInputDoc(put));          } catch (Exception ex) {              LOG.error(ex.getMessage());          }      }  }  1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.36.37.38.39.40.41.42.43.44.45.46.47.48.49.50.51.52.53.54.55.56.57.58.59.60.61.62.63.64.65.66.67.68.69.70.71.72.73.74.75.76.77.78.79.IT技术网

(责任编辑：域名)