org.eclipse.smila.importing.worker

Class UpdatePusherTaskGenerator

java.lang.Object

org.eclipse.smila.jobmanager.taskgenerator.TaskGeneratorBase

org.eclipse.smila.jobmanager.taskgenerator.DefaultTaskGenerator

org.eclipse.smila.importing.worker.UpdatePusherTaskGenerator

All Implemented Interfaces:

TaskGenerator

public class UpdatePusherTaskGenerator
extends DefaultTaskGenerator

task generator for UpdatePusherWorker:

• assert that either "jobToPushTo" or the "remote" section is set.
• create one completing task per shard in delta service, if delta-delete is enabled.

Field Summary

Fields inherited from class org.eclipse.smila.jobmanager.taskgenerator.TaskGeneratorBase

_objectStore, PROPERTY_GENERATOR_NAME

Constructor Summary

Constructors

Constructor and Description
UpdatePusherTaskGenerator()

Method Summary

Methods

Modifier and Type	Method and Description
java.util.List<Task>	createCompletionTasks(java.util.Map<java.lang.String,Bucket> inputBuckets, java.util.Map<java.lang.String,Bucket> outputBuckets, AnyMap parameters, java.lang.String workerName) create one completion task, without input/output bulks and no special parameters.
void	setDeltaService(DeltaService deltaService) DS service reference bind method.
void	unsetDeltaService(DeltaService deltaService) DS service reference unbind method.
void	validateParameters(AnyMap parameters) Check complex parameters in some task generators if desired.

Methods inherited from class org.eclipse.smila.jobmanager.taskgenerator.DefaultTaskGenerator

createCompletionTask, createInitialTask, createRunOnceTasks, createTasks, doCreateRunOnceTasks

Methods inherited from class org.eclipse.smila.jobmanager.taskgenerator.TaskGeneratorBase

activate, addOutputBulks, addOutputBulks, checkBucketCounts, createSingleBulkTask, createTask, createTaskId, createTasks, finishTask, getName, getParameterValue, getParameterValue, getParameterValue, setObjectStoreService, unsetObjectStoreService

Methods inherited from class java.lang.Object

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

Constructor Detail

UpdatePusherTaskGenerator

public UpdatePusherTaskGenerator()

Method Detail

validateParameters

public void validateParameters(AnyMap parameters)
                        throws TaskGeneratorException

Description copied from class: TaskGeneratorBase

Check complex parameters in some task generators if desired. Do nothing if no check desired.

Specified by:

validateParameters in interface TaskGenerator

Overrides:

validateParameters in class TaskGeneratorBase

Parameters:

parameters - The map with the parameters

Throws:

TaskGeneratorException - an exception if something is wrong with the parameters

createCompletionTasks

public java.util.List<Task> createCompletionTasks(java.util.Map<java.lang.String,Bucket> inputBuckets,
                                         java.util.Map<java.lang.String,Bucket> outputBuckets,
                                         AnyMap parameters,
                                         java.lang.String workerName)
                                           throws TaskGeneratorException

Description copied from class: DefaultTaskGenerator

create one completion task, without input/output bulks and no special parameters.

Specified by:

createCompletionTasks in interface TaskGenerator

Overrides:

createCompletionTasks in class DefaultTaskGenerator

Parameters:

inputBuckets - key: input slot name, value: bucket for this slot

outputBuckets - key: output slot name, value: bucket for this slot

parameters - key: param name, value: (evaluated) param value

workerName - (action) worker for which to create new tasks

Returns:

a list of new generated tasks

Throws:

TaskGeneratorException - error while generating tasks

setDeltaService

public void setDeltaService(DeltaService deltaService)

DS service reference bind method.

unsetDeltaService

public void unsetDeltaService(DeltaService deltaService)

DS service reference unbind method.