myui · October 29, 2016 01:41
diff --git a/lr.sql b/lr.sql
 CREATE TABLE lr_model AS
 SELECT
  feature, -- reducers perform model averaging in parallel
  avg(weight) as weight
 FROM (
  SELECT logress(features,label,..) as (feature,weight)
  FROM train
 ) t -- map-only task
 GROUP BY feature; -- shuffled to reducers
	CREATE TABLE lr_model AS
	SELECT
	feature, -- reducers perform model averaging in parallel
	avg(weight) as weight
	FROM (
	SELECT logress(features,label,..) as (feature,weight)
	FROM train
	) t -- map-only task
	GROUP BY feature; -- shuffled to reducers