rua

src/crane/worker.go

@@ -141,7 +141,7 @@ func processData(data Data) {
 	}
 	//fmt.Println(data.Tuple)
 	processedTuple := boltFunc(data.Tuple)
-	//fmt.Println(processedTuple)
+	fmt.Println(processedTuple)
 	newData := Data{ID: 0, Tuple: processedTuple, JobId: data.JobId}
 	// Send the processed data
 	if len(processedTuple) > 0 {