io.cloudex.framework.components

Class Coordinator.Builder

java.lang.Object

io.cloudex.framework.components.Coordinator.Builder

Enclosing class:

Coordinator

public static final class Coordinator.Builder
extends Object

Builder for Coordinator

Implementation is not thread-safe.

Constructor Summary

Constructors

Constructor and Description
Builder(Job job, CloudService cloudService)

Method Summary

Modifier and Type	Method and Description
Coordinator	build() Build a new instance of Coordinator
CloudService	getCloudService()
Job	getJob()
VmMetaData	getMetaData()
PartitionFunctionFactory	getPartitionFunctionFactory()
TaskFactory	getTaskFactory()
boolean	isShutdownProcessors()
Coordinator.Builder	setCloudService(CloudService cloudService)
Coordinator.Builder	setJob(Job job)
Coordinator.Builder	setMetaData(VmMetaData metaData)
Coordinator.Builder	setPartitionFunctionFactory(PartitionFunctionFactory partitionFunctionFactory)
Coordinator.Builder	setShutdownProcessors(boolean shutdownProcessors)
Coordinator.Builder	setTaskFactory(TaskFactory taskFactory)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder(Job job,
               CloudService cloudService)

Parameters:

job - - the job to execute

cloudService - - the cloud service implementation

Method Detail

build

public Coordinator build()
                  throws IOException

Build a new instance of Coordinator

Returns:

coordinator instance

Throws:

IOException - if cloud api calls fail

setJob

public Coordinator.Builder setJob(Job job)

Parameters:

job - the job to set

setMetaData

public Coordinator.Builder setMetaData(VmMetaData metaData)

Parameters:

metaData - the metaData to set

setCloudService

public Coordinator.Builder setCloudService(CloudService cloudService)

Parameters:

cloudService - the cloudService to set

setPartitionFunctionFactory

public Coordinator.Builder setPartitionFunctionFactory(PartitionFunctionFactory partitionFunctionFactory)

Parameters:

partitionFunctionFactory - the partitionFunctionFactory to set

setTaskFactory

public Coordinator.Builder setTaskFactory(TaskFactory taskFactory)

Parameters:

taskFactory - the taskFactory to set

getJob

public final Job getJob()

Returns:

the job

getMetaData

public final VmMetaData getMetaData()

Returns:

the metaData

getCloudService

public final CloudService getCloudService()

Returns:

the cloudService

getPartitionFunctionFactory

public final PartitionFunctionFactory getPartitionFunctionFactory()

Returns:

the partitionFunctionFactory

getTaskFactory

public final TaskFactory getTaskFactory()

Returns:

the taskFactory

isShutdownProcessors

public final boolean isShutdownProcessors()

Returns:

the shutdownProcessors

setShutdownProcessors

public final Coordinator.Builder setShutdownProcessors(boolean shutdownProcessors)

Parameters:

shutdownProcessors - the shutdownProcessors to set