org.apache.hadoop.tools.rumen

类 ZombieJobProducer

java.lang.Object

org.apache.hadoop.tools.rumen.ZombieJobProducer

所有已实现的接口:

Closeable, AutoCloseable, JobStoryProducer

public class ZombieJobProducer
extends Object
implements JobStoryProducer

Producing JobStorys from job trace.

构造器概要

构造器

构造器和说明
ZombieJobProducer(InputStream input, ZombieCluster cluster) Constructor
ZombieJobProducer(InputStream input, ZombieCluster cluster, long randomSeed) Constructor
ZombieJobProducer(Path path, ZombieCluster cluster, Configuration conf) Constructor
ZombieJobProducer(Path path, ZombieCluster cluster, Configuration conf, long randomSeed) Constructor

方法概要

方法

限定符和类型	方法和说明
void	close()
ZombieJob	getNextJob() Get the next job.

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

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

构造器详细资料

ZombieJobProducer

public ZombieJobProducer(Path path,
                 ZombieCluster cluster,
                 Configuration conf)
                  throws IOException

Constructor

参数:

path - Path to the JSON trace file, possibly compressed.

cluster - The topology of the cluster that corresponds to the jobs in the trace. The argument can be null if we do not have knowledge of the cluster topology.

conf -

抛出:

IOException

ZombieJobProducer

public ZombieJobProducer(Path path,
                 ZombieCluster cluster,
                 Configuration conf,
                 long randomSeed)
                  throws IOException

Constructor

参数:

path - Path to the JSON trace file, possibly compressed.

cluster - The topology of the cluster that corresponds to the jobs in the trace. The argument can be null if we do not have knowledge of the cluster topology.

conf -

randomSeed - use a deterministic seed.

抛出:

IOException

ZombieJobProducer

public ZombieJobProducer(InputStream input,
                 ZombieCluster cluster)
                  throws IOException

Constructor

参数:

input - The input stream for the JSON trace.

cluster - The topology of the cluster that corresponds to the jobs in the trace. The argument can be null if we do not have knowledge of the cluster topology.

抛出:

IOException

ZombieJobProducer

public ZombieJobProducer(InputStream input,
                 ZombieCluster cluster,
                 long randomSeed)
                  throws IOException

Constructor

参数:

input - The input stream for the JSON trace.

cluster - The topology of the cluster that corresponds to the jobs in the trace. The argument can be null if we do not have knowledge of the cluster topology.

randomSeed - use a deterministic seed.

抛出:

IOException

方法详细资料

getNextJob

public ZombieJob getNextJob()
                     throws IOException

从接口复制的说明: JobStoryProducer

Get the next job.

指定者:

getNextJob 在接口中 JobStoryProducer

返回:

The next job. Or null if no more job is available.

抛出:

IOException

close

public void close()
           throws IOException

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

抛出:

IOException