Interface PartitionerSupport
@DeveloperApi
public interface PartitionerSupport
Factory object responsible for creating
Partitioner operators. A partitioner operator will be
requested for each input dataset of workflow tasks; therefore, factory might implement singleton
partitioner object or create a new object each time when requested depending on the implementation,
e.g. thread safety.-
Method Summary
Modifier and TypeMethodDescriptioncreatePartitioner(PluginContext pluginContext, OperatorContext operatorContext) Returns a partitioner operator with specific plugin context and operator context that is created and initialized by SeqsLab workflow engine.
-
Method Details
-
createPartitioner
Returns a partitioner operator with specific plugin context and operator context that is created and initialized by SeqsLab workflow engine.- Parameters:
pluginContext- Plugin context returned from plugin initializationoperatorContext- Operator context containing configuration parameters and task inputs- Returns:
- A partitioner object
-