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
-