org.apache.hadoop.examples

类 RandomWriter

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.examples.RandomWriter

所有已实现的接口:

Configurable, Tool

public class RandomWriter
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 write a large unsorted random binary sequence file of BytesWritable. In order for this program to generate data for terasort with 10-byte keys and 90-byte values, have the following config: <?xml version="1.0"?> <?xml-stylesheet type="text/xsl" href="configuration.xsl"?> <configuration> <property> <name>test.randomwrite.min_key</name> <value>10</value> </property> <property> <name>test.randomwrite.max_key</name> <value>10</value> </property> <property> <name>test.randomwrite.min_value</name> <value>90</value> </property> <property> <name>test.randomwrite.max_value</name> <value>90</value> </property> <property> <name>test.randomwrite.total_bytes</name> <value>1099511627776</value> </property> </configuration> Equivalently, RandomWriter also supports all the above options and ones supported by GenericOptionsParser via the command-line.

构造器概要

构造器

构造器和说明
RandomWriter()

方法概要

方法

限定符和类型	方法和说明
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

构造器详细资料

RandomWriter

public RandomWriter()

方法详细资料

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