Method DisplayName

flow/dataset_shard.go:41–43

()

}

func (s *DatasetShard) DisplayName() string {
	return fmt.Sprintf("d%d_%d", s.Parent.Id, s.Id)
}

func (shard *DatasetShard) SetupReadingChans() {
	// get unique list of tasks since ReadingTasks can have duplicates