public class ZombieJobProducer extends Object implements JobStoryProducer
JobStory
s from job trace.Constructor and Description |
---|
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
|
public ZombieJobProducer(Path path, ZombieCluster cluster, Configuration conf) throws IOException
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
public ZombieJobProducer(Path path, ZombieCluster cluster, Configuration conf, long randomSeed) throws IOException
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
public ZombieJobProducer(InputStream input, ZombieCluster cluster) throws IOException
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
public ZombieJobProducer(InputStream input, ZombieCluster cluster, long randomSeed) throws IOException
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
public ZombieJob getNextJob() throws IOException
JobStoryProducer
getNextJob
in interface JobStoryProducer
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.