PipelineJobProgressPersistService (shardingsphere-data-pipeline-core 5.2.1 API)

java.lang.Object
- org.apache.shardingsphere.data.pipeline.core.job.progress.persist.PipelineJobProgressPersistService

public final class PipelineJobProgressPersistService
extends Object

Pipeline job progress persist service.

构造器
构造器和说明
`PipelineJobProgressPersistService()`

所有方法静态方法具体方法
限定符和类型	方法和说明
`static void`	`addJobProgressPersistContext(String jobId, int shardingItem)` Add job progress persist context.
`static void`	`notifyPersist(String jobId, int shardingItem)` Notify persist.
`static void`	`removeJobProgressPersistContext(String jobId)` Remove job progress persist context.

构造器详细资料
- PipelineJobProgressPersistService
```
public PipelineJobProgressPersistService()
```

public static void addJobProgressPersistContext(String jobId,
                                                int shardingItem)

Add job progress persist context.

public static void notifyPersist(String jobId,
                                 int shardingItem)

Notify persist.

类 PipelineJobProgressPersistService