Function FromDatasetToStep

flow/context.go:158–164

(input *Dataset, step *Step)

}

func FromDatasetToStep(input *Dataset, step *Step) {
	if input == nil {
		return
	}
	step.Inputs = append(step.Inputs, input)
	input.ReadingSteps = append(input.ReadingSteps, step)
}

func FromDatasetShardToTask(shard *DatasetShard, task *Task) {
	shard.ReadingTasks = append(shard.ReadingTasks, task)