func (tc SimpleTaskBuilder) GetTask(taskID uint64) taskgraph.Task {
	if taskID == 0 {
		return &dummyMaster{
			dataChan:           tc.GDataChan,
			NodeProducer:       tc.NodeProducer,
			config:             tc.MasterConfig,
			numberOfIterations: tc.NumberOfIterations,
		}
	}
	return &dummySlave{
		NodeProducer: tc.NodeProducer,
		config:       tc.SlaveConfig,
	}
}
// This method is called once by framework implementation to get the
// right task implementation for the node/task. It requires the taskID
// for current node, and also a global array of tasks.
This method is called once by framework implementation to get the
right task implementation for the node/task. It requires the taskID
for current node, and also a global array of tasks.
// This method is called once by framework implementation to get the // right task implementation for the node / task . It requires the taskID // for current node and also a global array of tasks .
func (tc SimpleTaskBuilder) GetTask(taskID uint64) taskgraph.Task {
	if taskID == 0 {
		return &dummyMaster{
			dataChan:           tc.GDataChan,
			NodeProducer:       tc.NodeProducer,
			config:             tc.MasterConfig,
			numberOfIterations: tc.NumberOfIterations,
		}
	}
	return &dummySlave{
		NodeProducer: tc.NodeProducer,
		config:       tc.SlaveConfig,
	}
}
func ( tc SimpleTaskBuilder ) GetTask ( taskID uint64 ) taskgraph . Task { if taskID == 0 { return & dummyMaster { dataChan : tc . GDataChan , NodeProducer : tc . NodeProducer , config : tc . MasterConfig , numberOfIterations : tc . NumberOfIterations , } } return & dummySlave { NodeProducer : tc . NodeProducer , config : tc . SlaveConfig , } }
This method is called once by framework implementation to get the
right task implementation for the node/task.
This method is called once by framework implementation to get the right task implementation for the node / task .