Interface TaskPartitionsDefinition

  • All Known Implementing Classes:
    StaticTaskPartitionsDefinition

    public interface TaskPartitionsDefinition
    Configuration for PartitioningTaskHandler: describes how to create subtasks (partitions) for the given master task. Templates can contain the following macros: - {index}: number of the subtask, starting at 1 - {masterTaskName}: name of the master task - {masterTaskHandlerUri}: URI of the master task handler
    Author:
    mederly
    • Method Detail

      • getCount

        int getCount​(Task masterTask)
        Number of partitions.
      • isSequentialExecution

        default boolean isSequentialExecution​(Task masterTask)
        Whether the subtasks should be executed sequentially.
      • isDurablePartitions

        default boolean isDurablePartitions​(Task masterTask)
        Whether the partitions should be durable i.e. whether they should persist through master task restarts. This is useful e.g. for partitioned validity scanner because each partition keeps its own last scan timestamp. (EXPERIMENTAL)
      • getName

        default String getName​(Task masterTask)
        Template for the subtask name. The default is {masterTaskName} ({index})
      • getHandlerUri

        default String getHandlerUri​(Task masterTask)
        Handler URI for the subtask. The default is {masterTaskHandlerUri}#{index}
      • isCopyMasterExtension

        default Boolean isCopyMasterExtension​(Task masterTask)
        Whether to copy extension from master task into subtask.
      • getOtherDeltas

        @NotNull
        default Collection<ItemDelta<?,​?>> getOtherDeltas​(Task masterTask)
        Deltas to be applied to subtask after its creation. Applied before strategy.otherDeltas.