be.bagofwords.jobs

Class JobRunner

java.lang.Object

be.bagofwords.jobs.JobRunner

All Implemented Interfaces:

CloseableComponent

public class JobRunner
extends Object
implements CloseableComponent

Constructor Summary

Constructors

Constructor and Description
JobRunner()

Method Summary

Modifier and Type	Method and Description
String	createHtmlStatus()
<T> void	runJob(boolean printProgress, int numOfThreads, String name, DataIterable<T> iterable, Job<T> job)
<T> void	runJob(int numOfThreads, String name, DataIterable<T> iterable, Job<T> job)
<T> void	runJob(String name, DataIterable<T> iterable, Job<T> job)
<T> void	runPartitionedJobs(boolean printProgress, int numOfPartitions, int numOfThreads, String name, DataIterable<T> iterable, PartitionableJob<T> job)
<T> void	runPartitionedJobs(int numOfPartitions, int numOfThreads, String name, DataIterable<T> iterable, PartitionableJob<T> job)
void	terminate()

Methods inherited from class java.lang.Object

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

Constructor Detail

JobRunner

public JobRunner()

Method Detail

runPartitionedJobs

public <T> void runPartitionedJobs(int numOfPartitions,
                                   int numOfThreads,
                                   String name,
                                   DataIterable<T> iterable,
                                   PartitionableJob<T> job)

runPartitionedJobs

public <T> void runPartitionedJobs(boolean printProgress,
                                   int numOfPartitions,
                                   int numOfThreads,
                                   String name,
                                   DataIterable<T> iterable,
                                   PartitionableJob<T> job)

runJob

public <T> void runJob(int numOfThreads,
                       String name,
                       DataIterable<T> iterable,
                       Job<T> job)

runJob

public <T> void runJob(boolean printProgress,
                       int numOfThreads,
                       String name,
                       DataIterable<T> iterable,
                       Job<T> job)

runJob

public <T> void runJob(String name,
                       DataIterable<T> iterable,
                       Job<T> job)

createHtmlStatus

public String createHtmlStatus()

terminate

public void terminate()

Specified by:

terminate in interface CloseableComponent