代码拉取完成,页面将自动刷新
同步操作将从 chararch/gobatch 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
package gobatch
import "fmt"
type jobBuilder struct {
name string
steps []Step
jobListeners []JobListener
stepListeners []StepListener
chunkListeners []ChunkListener
partitionListeners []PartitionListener
}
//NewJob new instance of job builder
func NewJob(name string, steps ...Step) *jobBuilder {
if name == "" {
panic("job name must not be empty")
}
builder := &jobBuilder{
name: name,
steps: steps,
}
return builder
}
func (builder *jobBuilder) Step(step ...Step) *jobBuilder {
builder.steps = append(builder.steps, step...)
return builder
}
func (builder *jobBuilder) Listener(listener ...interface{}) *jobBuilder {
for _, l := range listener {
switch ll := l.(type) {
case JobListener:
builder.jobListeners = append(builder.jobListeners, ll)
case StepListener:
builder.stepListeners = append(builder.stepListeners, ll)
case ChunkListener:
builder.chunkListeners = append(builder.chunkListeners, ll)
case PartitionListener:
builder.partitionListeners = append(builder.partitionListeners, ll)
default:
panic(fmt.Sprintf("not supported listener:%+v for job:%v", ll, builder.name))
}
}
return builder
}
func (builder *jobBuilder) Build() Job {
var job Job
for _, sl := range builder.stepListeners {
for _, step := range builder.steps {
step.addListener(sl)
}
}
for _, cl := range builder.chunkListeners {
for _, step := range builder.steps {
if chkStep, ok := step.(*chunkStep); ok {
chkStep.addChunkListener(cl)
}
}
}
for _, pl := range builder.partitionListeners {
for _, step := range builder.steps {
if chkStep, ok := step.(*partitionStep); ok {
chkStep.addPartitionListener(pl)
}
}
}
job = newSimpleJob(builder.name, builder.steps, builder.jobListeners)
return job
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。