StreamJob (Hadoop 1.2.2-SNAPSHOT API)

java.lang.Object
- org.apache.hadoop.streaming.StreamJob

所有已实现的接口:

Configurable, Tool
```
public class StreamJob
extends Object
implements Tool
```
All the client-side work happens here. (Jar packaging, MapRed job submission and monitoring)

字段概要

字段
限定符和类型	字段和说明
`protected String`	`additionalConfSpec_`
`protected String`	`addTaskEnvironment_`
`protected URI[]`	`archiveURIs`
`protected String[]`	`argv_`
`protected String`	`cacheArchives`
`protected String`	`cacheFiles`
`protected String`	`comCmd_`
`protected Configuration`	`config_`
`protected int`	`debug_`
`protected boolean`	`detailedUsage_`
`protected Environment`	`env_`
`protected URI[]`	`fileURIs`
`protected boolean`	`hasSimpleInputSpecs_`
`protected String`	`inputFormatSpec_`
`protected ArrayList`	`inputSpecs_`
`protected String`	`inReaderSpec_`
`protected String`	`ioSpec_`
`protected String`	`jar_`
`protected JobClient`	`jc_`
`protected JobConf`	`jobConf_`
`protected JobID`	`jobId_`
`protected static String`	`LINK_URI`
`protected boolean`	`localHadoop_`
`protected static org.apache.commons.logging.Log`	`LOG`
`protected String`	`mapCmd_`
`protected String`	`mapDebugSpec_`
`protected long`	`minRecWrittenToEnableSkip_`
`protected String`	`numReduceTasksSpec_`
`protected String`	`output_`
`protected String`	`outputFormatSpec_`
`protected boolean`	`outputSingleNode_`
`protected ArrayList`	`packageFiles_`
`protected String`	`partitionerSpec_`
`protected String`	`redCmd_`
`protected String`	`reduceDebugSpec_`
`protected RunningJob`	`running_`
`protected TreeSet`	`seenPrimary_`
`protected ArrayList`	`shippedCanonFiles_`
`protected boolean`	`verbose_`

构造器概要

构造器
构造器和说明
`StreamJob()`
`StreamJob(String[] argv, boolean mayExit)` 已过时。 use StreamJob() with ToolRunner or set the Configuration using `setConf(Configuration)` and run with `run(String[])`.

方法概要

方法
限定符和类型	方法和说明
`static JobConf`	`createJob(String[] argv)` This method creates a streaming job from the given argument list.
`void`	`exitUsage(boolean detailed)`
`void`	`fail(String message)`
`protected String`	`getClusterNick()` 已过时。
`Configuration`	`getConf()` Return the configuration used by this object.
`protected String`	`getHadoopClientHome()`
`protected String`	`getJobTrackerHostPort()`
`protected void`	`getURIs(String lcacheArchives, String lcacheFiles)` get the uris of all the files/caches
`int`	`go()` 已过时。 use `run(String[])` instead.
`protected void`	`init()`
`protected boolean`	`isLocalHadoop()`
`protected void`	`jobInfo()`
`protected void`	`listJobConfProperties()` Prints out the jobconf properties on stdout when verbose is specified.
`protected void`	`msg(String msg)`
`protected String`	`packageJobJar()`
`int`	`run(String[] args)` Execute the command with the given arguments.
`void`	`setConf(Configuration conf)` Set the configuration to be used by this object.
`protected void`	`setJobConf()`
`int`	`submitAndMonitorJob()`

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

LOG

protected static final org.apache.commons.logging.Log LOG

argv_
```
protected String[] argv_
```

verbose_
```
protected boolean verbose_
```

detailedUsage_
```
protected boolean detailedUsage_
```

debug_
```
protected int debug_
```

env_
```
protected Environment env_
```

jar_
```
protected String jar_
```

localHadoop_
```
protected boolean localHadoop_
```

config_
```
protected Configuration config_
```

jobConf_
```
protected JobConf jobConf_
```

jc_
```
protected JobClient jc_
```

inputSpecs_
```
protected ArrayList inputSpecs_
```

seenPrimary_
```
protected TreeSet seenPrimary_
```

hasSimpleInputSpecs_
```
protected boolean hasSimpleInputSpecs_
```

packageFiles_
```
protected ArrayList packageFiles_
```

shippedCanonFiles_
```
protected ArrayList shippedCanonFiles_
```

output_
```
protected String output_
```

mapCmd_
```
protected String mapCmd_
```

comCmd_
```
protected String comCmd_
```

redCmd_
```
protected String redCmd_
```

cacheFiles
```
protected String cacheFiles
```

cacheArchives
```
protected String cacheArchives
```

fileURIs
```
protected URI[] fileURIs
```

archiveURIs
```
protected URI[] archiveURIs
```

inReaderSpec_
```
protected String inReaderSpec_
```

inputFormatSpec_
```
protected String inputFormatSpec_
```

outputFormatSpec_
```
protected String outputFormatSpec_
```

partitionerSpec_
```
protected String partitionerSpec_
```

numReduceTasksSpec_
```
protected String numReduceTasksSpec_
```

additionalConfSpec_
```
protected String additionalConfSpec_
```

mapDebugSpec_
```
protected String mapDebugSpec_
```

reduceDebugSpec_
```
protected String reduceDebugSpec_
```

ioSpec_
```
protected String ioSpec_
```

addTaskEnvironment_
```
protected String addTaskEnvironment_
```

outputSingleNode_
```
protected boolean outputSingleNode_
```

minRecWrittenToEnableSkip_

protected long minRecWrittenToEnableSkip_

running_
```
protected RunningJob running_
```

jobId_
```
protected JobID jobId_
```

LINK_URI
```
protected static final String LINK_URI
```
另请参阅:
常量字段值

构造器详细资料
- StreamJob
```
@Deprecated
public StreamJob(String[] argv,
                    boolean mayExit)
```
  已过时。 use StreamJob() with ToolRunner or set the Configuration using setConf(Configuration) and run with run(String[]).
- StreamJob
```
public StreamJob()
```

方法详细资料
- getConf
```
public Configuration getConf()
```
  从接口复制的说明: Configurable
  
  Return the configuration used by this object.
  
  指定者:
  
  getConf 在接口中 Configurable
- setConf
```
public void setConf(Configuration conf)
```
  从接口复制的说明: Configurable
  
  Set the configuration to be used by this object.
  
  指定者:
  
  setConf 在接口中 Configurable
- run
```
public int run(String[] args)
        throws Exception
```
  从接口复制的说明: Tool
  
  Execute the command with the given arguments.
  
  指定者:
  
  run 在接口中 Tool
  
  参数:
  args - command specific arguments.
  
  返回:
  exit code.
  
  抛出:
  
  Exception
- createJob
```
public static JobConf createJob(String[] argv)
                         throws IOException
```
  This method creates a streaming job from the given argument list. The created object can be used and/or submitted to a jobtracker for execution by a job agent such as JobControl
  
  参数:
  argv - the list args for creating a streaming job
  
  返回:
  the created JobConf object
  
  抛出:
  
  IOException
- go
```
@Deprecated
public int go()
       throws IOException
```
  已过时。 use run(String[]) instead.
  
  This is the method that actually intializes the job conf and submits the job to the jobtracker
  
  抛出:
  
  IOException
- init
```
protected void init()
```
- msg
```
protected void msg(String msg)
```
- exitUsage
```
public void exitUsage(boolean detailed)
```
- fail
```
public void fail(String message)
```
- getHadoopClientHome
```
protected String getHadoopClientHome()
```
- isLocalHadoop
```
protected boolean isLocalHadoop()
```
- getClusterNick
```
@Deprecated
protected String getClusterNick()
```
  已过时。
- packageJobJar
```
protected String packageJobJar()
                        throws IOException
```
  返回:
  path to the created Jar file or null if no files are necessary.
  
  抛出:
  
  IOException
- getURIs
```
protected void getURIs(String lcacheArchives,
           String lcacheFiles)
```
  get the uris of all the files/caches
- setJobConf
```
protected void setJobConf()
                   throws IOException
```
  抛出:
  
  IOException
- listJobConfProperties
```
protected void listJobConfProperties()
```
  Prints out the jobconf properties on stdout when verbose is specified.
- getJobTrackerHostPort
```
protected String getJobTrackerHostPort()
```
- jobInfo
```
protected void jobInfo()
```
- submitAndMonitorJob
```
public int submitAndMonitorJob()
                        throws IOException
```
  抛出:
  
  IOException

类 StreamJob

字段概要

构造器概要

方法概要

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

字段详细资料

LOG

argv_

verbose_

detailedUsage_

debug_

env_

jar_

localHadoop_

config_

jobConf_

jc_

inputSpecs_

seenPrimary_

hasSimpleInputSpecs_

packageFiles_

shippedCanonFiles_

output_

mapCmd_

comCmd_

redCmd_

cacheFiles

cacheArchives

fileURIs

archiveURIs

inReaderSpec_

inputFormatSpec_

outputFormatSpec_

partitionerSpec_

numReduceTasksSpec_

additionalConfSpec_

mapDebugSpec_

reduceDebugSpec_

ioSpec_

addTaskEnvironment_

outputSingleNode_

minRecWrittenToEnableSkip_

running_

jobId_

LINK_URI

构造器详细资料

StreamJob

StreamJob

方法详细资料

getConf

setConf

run

createJob

go

init

msg

exitUsage

fail

getHadoopClientHome

isLocalHadoop

getClusterNick

packageJobJar

getURIs

setJobConf

listJobConfProperties

getJobTrackerHostPort

jobInfo

submitAndMonitorJob