import org.apache.hadoop.contrib.index.mapred.Shard; //导入依赖的package包/类
/**
 * Constructor
 * @param fs
 * @param shard
 * @param tempDir
 * @param iconf
 * @throws IOException
 */
public ShardWriter(FileSystem fs, Shard shard, String tempDir,
    IndexUpdateConfiguration iconf) throws IOException {
  LOG.info("Construct a shard writer");

  this.fs = fs;
  localFs = FileSystem.getLocal(iconf.getConfiguration());
  perm = new Path(shard.getDirectory());
  temp = new Path(tempDir);

  long initGeneration = shard.getGeneration();
  if (!fs.exists(perm)) {
    assert (initGeneration < 0);
    fs.mkdirs(perm);
  } else {
    restoreGeneration(fs, perm, initGeneration);
  }
  dir =
      new MixedDirectory(fs, perm, localFs, fs.startLocalOutput(perm, temp),
          iconf.getConfiguration());

  // analyzer is null because we only use addIndexes, not addDocument
  writer =
      new IndexWriter(dir, false, null,
          initGeneration < 0 ? new KeepOnlyLastCommitDeletionPolicy()
              : new MixedDeletionPolicy());
  setParameters(iconf);
}
 

import org.apache.hadoop.contrib.index.mapred.Shard; //导入依赖的package包/类
public void init(Shard[] shards) {
  numShards = shards.length;
}
 

import org.apache.hadoop.contrib.index.mapred.Shard; //导入依赖的package包/类
public void init(Shard[] shards) {
  numShards = shards.length;
  rr = 0;
}