类 org.apache.hadoop.contrib.index.mapred.Shard
的使用

使用Shard的程序包

程序包	说明
org.apache.hadoop.contrib.index.example
org.apache.hadoop.contrib.index.lucene
org.apache.hadoop.contrib.index.mapred

org.apache.hadoop.contrib.index.example中Shard的使用

参数类型为Shard的org.apache.hadoop.contrib.index.example中的方法

限定符和类型	方法和说明
void	RoundRobinDistributionPolicy.init(Shard[] shards)
void	HashingDistributionPolicy.init(Shard[] shards)

org.apache.hadoop.contrib.index.lucene中Shard的使用

参数类型为Shard的org.apache.hadoop.contrib.index.lucene中的构造器

构造器和说明
ShardWriter(FileSystem fs, Shard shard, String tempDir, IndexUpdateConfiguration iconf) Constructor

org.apache.hadoop.contrib.index.mapred中Shard的使用

返回Shard的org.apache.hadoop.contrib.index.mapred中的方法

限定符和类型	方法和说明
static Shard[]	Shard.getIndexShards(IndexUpdateConfiguration conf)

返回变量类型为Shard的类型的org.apache.hadoop.contrib.index.mapred中的方法

限定符和类型	方法和说明
RecordWriter<Shard,Text>	IndexUpdateOutputFormat.getRecordWriter(FileSystem fs, JobConf job, String name, Progressable progress)

参数类型为Shard的org.apache.hadoop.contrib.index.mapred中的方法

限定符和类型	方法和说明
int	Shard.compareTo(Shard other) Compare to another shard.
int	IndexUpdatePartitioner.getPartition(Shard key, IntermediateForm value, int numPartitions)
void	IDistributionPolicy.init(Shard[] shards) Initialization.
void	IndexUpdateCombiner.reduce(Shard key, Iterator<IntermediateForm> values, OutputCollector<Shard,IntermediateForm> output, Reporter reporter)
void	IndexUpdateReducer.reduce(Shard key, Iterator<IntermediateForm> values, OutputCollector<Shard,Text> output, Reporter reporter)
void	IndexUpdater.run(Configuration conf, Path[] inputPaths, Path outputPath, int numMapTasks, Shard[] shards)
void	IIndexUpdater.run(Configuration conf, Path[] inputPaths, Path outputPath, int numMapTasks, Shard[] shards) Create a Map/Reduce job configuration and run the Map/Reduce job to analyze documents and update Lucene instances in parallel.
static void	Shard.setIndexShards(IndexUpdateConfiguration conf, Shard[] shards)

类型变量类型为Shard的org.apache.hadoop.contrib.index.mapred中的方法参数

限定符和类型	方法和说明
void	IndexUpdateMapper.map(K key, V value, OutputCollector<Shard,IntermediateForm> output, Reporter reporter) Map a key-value pair to a shard-and-intermediate form pair.
void	IndexUpdateCombiner.reduce(Shard key, Iterator<IntermediateForm> values, OutputCollector<Shard,IntermediateForm> output, Reporter reporter)
void	IndexUpdateReducer.reduce(Shard key, Iterator<IntermediateForm> values, OutputCollector<Shard,Text> output, Reporter reporter)

参数类型为Shard的org.apache.hadoop.contrib.index.mapred中的构造器

构造器和说明
Shard(Shard shard) Construct using a shard object.