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

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

CombineInputWithAllTaskGenerator()

Method Summary

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.

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

activate, addOutputBulks, checkBucketCounts, createRunOnceTasks, createSingleBulkTask, createTask, createTaskId, extractAndOverwriteParameters, 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