org.apache.hadoop.examples

类 RandomTextWriter

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.examples.RandomTextWriter

所有已实现的接口:

Configurable, Tool

public class RandomTextWriter
extends Configured
implements Tool

This program uses map/reduce to just run a distributed job where there is no interaction between the tasks and each task writes a large unsorted random sequence of words. In order for this program to generate data for terasort with a 5-10 words per key and 20-100 words per value, have the following config: <?xml version="1.0"?> <?xml-stylesheet type="text/xsl" href="configuration.xsl"?> <configuration> <property> <name>test.randomtextwrite.min_words_key</name> <value>5</value> </property> <property> <name>test.randomtextwrite.max_words_key</name> <value>10</value> </property> <property> <name>test.randomtextwrite.min_words_value</name> <value>20</value> </property> <property> <name>test.randomtextwrite.max_words_value</name> <value>100</value> </property> <property> <name>test.randomtextwrite.total_bytes</name> <value>1099511627776</value> </property> </configuration> Equivalently, RandomTextWriter also supports all the above options and ones supported by Tool via the command-line. To run: bin/hadoop jar hadoop-${version}-examples.jar randomtextwriter [-outFormat output format class] output

构造器概要

构造器

构造器和说明
RandomTextWriter()

方法概要

方法

限定符和类型	方法和说明
static void	main(String[] args)
int	run(String[] args) This is the main routine for launching a distributed random write job.

从类继承的方法 org.apache.hadoop.conf.Configured

getConf, setConf

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.hadoop.conf.Configurable

getConf, setConf

构造器详细资料

RandomTextWriter

public RandomTextWriter()

方法详细资料

run

public int run(String[] args)
        throws Exception

This is the main routine for launching a distributed random write job. It runs 10 maps/node and each node writes 1 gig of data to a DFS file. The reduce doesn't do anything.

指定者:

run 在接口中 Tool

参数:

args - command specific arguments.

返回:

exit code.

抛出:

IOException

Exception

main

public static void main(String[] args)
                 throws Exception

抛出:

Exception