org.eclipse.smila.jobmanager.taskgenerator

Class CombineInputWithAllTaskGenerator

java.lang.Object

org.eclipse.smila.jobmanager.taskgenerator.TaskGeneratorBase

org.eclipse.smila.jobmanager.taskgenerator.CombineInputWithAllTaskGenerator

All Implemented Interfaces:

TaskGenerator

public class CombineInputWithAllTaskGenerator
extends TaskGeneratorBase

TaskGenerator for two input buckets that generates tasks for each combination of: [changed input bulk of first bucket X (all) object(s) from second input bucket] If the second input bucket is empty, no tasks will be generated.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	PARAMETER_PARTNER_PREFIX Prefix for partner parameter.
static java.lang.String	PARAMETER_TRIGGERED_BY parameter for triggered by.

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

_log, _objectStore, PROPERTY_GENERATOR_NAME

Constructor Summary

Constructors

Constructor and Description
CombineInputWithAllTaskGenerator()

Method Summary

Methods

Modifier and Type	Method and Description
java.util.List<Task>	createTasks(java.util.Map<java.lang.String,java.util.List<BulkInfo>> changedInput, java.util.Map<java.lang.String,Bucket> inputBuckets, java.util.Map<java.lang.String,Bucket> outputBuckets, AnyMap parameters, java.lang.String workerName) Generate task by combining changed bulk with each bulk from the other bucket.
protected java.util.Collection<StoreObject>	getObjectsFromBucket(Bucket bucket)

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

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

Methods inherited from class java.lang.Object

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

Field Detail

PARAMETER_PARTNER_PREFIX

public static final java.lang.String PARAMETER_PARTNER_PREFIX

Prefix for partner parameter.

See Also:

Constant Field Values

PARAMETER_TRIGGERED_BY

public static final java.lang.String PARAMETER_TRIGGERED_BY

parameter for triggered by.

See Also:

Constant Field Values

Constructor Detail

CombineInputWithAllTaskGenerator

public CombineInputWithAllTaskGenerator()

Method Detail

createTasks

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

Generate task by combining changed bulk with each bulk from the other bucket. For each changed input bulk:

• first input bucket is bucket of changed bulk
• second input bucket is other bucket from allInput
• read all objects from objectstore for second input bucket
• create a task for each combination of [changed bulk X object from second store]
• but no duplicates

Parameters:

changedInput - key: slot containing added bulks, value: added bulks

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

getObjectsFromBucket

protected java.util.Collection<StoreObject> getObjectsFromBucket(Bucket bucket)
                                                          throws TaskGeneratorException

Returns:

all objects from the bucket with a size greater than 0.

Throws:

TaskGeneratorException