code: public void configure(JobConf job) {
      iconf = new IndexUpdateConfiguration(job);
      analyzer =
          (Analyzer) ReflectionUtils.newInstance(
              iconf.getDocumentAnalyzerClass(), job);
  
      localAnalysis =
          (ILocalAnalysis) ReflectionUtils.newInstance(
              iconf.getLocalAnalysisClass(), job);
      localAnalysis.configure(job);
  
      shards = Shard.getIndexShards(iconf);
  
      distributionPolicy =
          (IDistributionPolicy) ReflectionUtils.newInstance(
              iconf.getDistributionPolicyClass(), job);
      distributionPolicy.init(shards);
  
      LOG.info("sea.document.analyzer = " + analyzer.getClass().getName());
      LOG.info("sea.local.analysis = " + localAnalysis.getClass().getName());
      LOG.info(shards.length + " shards = " + iconf.getIndexShards());
      LOG.info("sea.distribution.policy = "
          + distributionPolicy.getClass().getName());
    }
docs: /* (non-Javadoc)
  @see org.apache.hadoop.mapred.MapReduceBase#configure(org.apache.hadoop.mapred.JobConf)