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 Type
    Method
    Description
    createPartitioner(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

      Partitioner createPartitioner(PluginContext pluginContext, OperatorContext operatorContext)
      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 initialization
      operatorContext - Operator context containing configuration parameters and task inputs
      Returns:
      A partitioner object