Function StartSingleMachineJob

singleMachine.go:10–15

(input []string, plugin string, nReducer int, nWorker int, inRAM bool)

var MasterIP string = ":10000"

func StartSingleMachineJob(input []string, plugin string, nReducer int, nWorker int, inRAM bool) {
	if len(input) == 0 {
		os.Exit(0)
	}
	singleMachineJob(input, nWorker, nReducer, plugin, inRAM)
}

func singleMachineJob(input []string, nWorker int, nReducer int, plugin string, storeInRAM bool) {
	var wg sync.WaitGroup