Package com.floragunn.searchsupport.jobs.cluster

Class JobDistributor

java.lang.Object

com.floragunn.searchsupport.jobs.cluster.JobDistributor

All Implemented Interfaces:

AutoCloseable

public class JobDistributor
extends Object
implements AutoCloseable

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.logging.log4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
JobDistributor(String name, String nodeFilter, org.elasticsearch.cluster.service.ClusterService clusterService, DistributedJobStore distributedJobStore)
JobDistributor(String name, String nodeFilter, org.elasticsearch.cluster.service.ClusterService clusterService, DistributedJobStore distributedJobStore, NodeComparator<?> nodeComparator)

Method Summary

Modifier and Type	Method	Description
void	close()
DistributedJobStore	getDistributedJobStore()
boolean	isJobSelected(JobConfig jobConfig)
boolean	isJobSelected(JobConfig jobConfig, int nodeIndex)
void	setDistributedJobStore(DistributedJobStore distributedJobStore)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final org.apache.logging.log4j.Logger log

Constructor Detail

JobDistributor

public JobDistributor(String name,
                      String nodeFilter,
                      org.elasticsearch.cluster.service.ClusterService clusterService,
                      DistributedJobStore distributedJobStore)

JobDistributor

public JobDistributor(String name,
                      String nodeFilter,
                      org.elasticsearch.cluster.service.ClusterService clusterService,
                      DistributedJobStore distributedJobStore,
                      NodeComparator<?> nodeComparator)

Method Detail

isJobSelected

public boolean isJobSelected(JobConfig jobConfig)

isJobSelected

public boolean isJobSelected(JobConfig jobConfig,
                             int nodeIndex)

toString

public String toString()

Overrides:

toString in class Object

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

getDistributedJobStore

public DistributedJobStore getDistributedJobStore()

setDistributedJobStore

public void setDistributedJobStore(DistributedJobStore distributedJobStore)