Multiple: Add quoted input params for tests This commit updates install-check tests to use quoted string inputs.
Project: http://git-wip-us.apache.org/repos/asf/incubator-madlib/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-madlib/commit/f1aa9af6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-madlib/tree/f1aa9af6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-madlib/diff/f1aa9af6 Branch: refs/heads/master Commit: f1aa9af6271fa3abdae4e73f5bda4c8cc7912947 Parents: f63adda Author: Rahul Iyer <ri...@apache.org> Authored: Wed Aug 16 22:16:03 2017 -0700 Committer: Rahul Iyer <ri...@apache.org> Committed: Fri Aug 18 16:29:15 2017 -0700 ---------------------------------------------------------------------- methods/sketch/src/pg_gp/sql/cm.sql_in | 22 +++--- methods/sketch/src/pg_gp/sql/fm.sql_in | 16 ++--- methods/sketch/src/pg_gp/sql/mfv.sql_in | 6 +- .../postgres/modules/convex/test/mlp.sql_in | 26 ++++---- .../postgres/modules/graph/test/apsp.sql_in | 32 ++++----- .../postgres/modules/graph/test/bfs.sql_in | 70 ++++++++++---------- .../postgres/modules/graph/test/measures.sql_in | 34 +++++----- .../postgres/modules/graph/test/pagerank.sql_in | 14 ++-- .../postgres/modules/graph/test/sssp.sql_in | 24 +++---- .../postgres/modules/graph/test/wcc.sql_in | 12 ++-- src/ports/postgres/modules/knn/test/knn.sql_in | 18 ++--- .../sample/test/stratified_sample.sql_in | 18 ++--- .../modules/utilities/test/pivot.sql_in | 14 ++-- .../modules/utilities/test/sessionize.sql_in | 8 ++- 14 files changed, 159 insertions(+), 155 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/f1aa9af6/methods/sketch/src/pg_gp/sql/cm.sql_in ---------------------------------------------------------------------- diff --git a/methods/sketch/src/pg_gp/sql/cm.sql_in b/methods/sketch/src/pg_gp/sql/cm.sql_in index f7ab910..2731c56 100644 --- a/methods/sketch/src/pg_gp/sql/cm.sql_in +++ b/methods/sketch/src/pg_gp/sql/cm.sql_in @@ -18,16 +18,16 @@ declare begin -- DROP TABLE IF EXISTS data; - CREATE TABLE cm_data(class INT, a1 INT); - INSERT INTO cm_data SELECT 1,1 FROM generate_series(1,10000); - INSERT INTO cm_data SELECT 1,2 FROM generate_series(1,15000); - INSERT INTO cm_data SELECT 1,3 FROM generate_series(1,10000); - INSERT INTO cm_data SELECT 2,5 FROM generate_series(1,1000); - INSERT INTO cm_data SELECT 2,6 FROM generate_series(1,1000); + CREATE TABLE "CM_DATA"(class INT, a1 INT); + INSERT INTO "CM_DATA" SELECT 1,1 FROM generate_series(1,10000); + INSERT INTO "CM_DATA" SELECT 1,2 FROM generate_series(1,15000); + INSERT INTO "CM_DATA" SELECT 1,3 FROM generate_series(1,10000); + INSERT INTO "CM_DATA" SELECT 2,5 FROM generate_series(1,1000); + INSERT INTO "CM_DATA" SELECT 2,6 FROM generate_series(1,1000); -- DROP TABLE IF EXISTS result_table; CREATE TABLE cm_result_table AS - SELECT (MADLIB_SCHEMA.cmsketch_count(MADLIB_SCHEMA.cmsketch(a1),2)) as val FROM cm_data GROUP BY class ORDER BY class; + SELECT (MADLIB_SCHEMA.cmsketch_count(MADLIB_SCHEMA.cmsketch(a1),2)) as val FROM "CM_DATA" GROUP BY class ORDER BY class; SELECT array( SELECT val FROM cm_result_table) INTO result; IF ((result[1] + result[2]) != 15000) THEN @@ -36,7 +36,7 @@ begin TRUNCATE cm_result_table; INSERT INTO cm_result_table - SELECT MADLIB_SCHEMA.cmsketch_rangecount(MADLIB_SCHEMA.cmsketch(a1),3,6) FROM cm_data GROUP BY class ORDER BY class; + SELECT MADLIB_SCHEMA.cmsketch_rangecount(MADLIB_SCHEMA.cmsketch(a1),3,6) FROM "CM_DATA" GROUP BY class ORDER BY class; SELECT array( SELECT val FROM cm_result_table) INTO result; IF (result[1] + result[2] != 12000) THEN @@ -44,13 +44,13 @@ begin END IF; TRUNCATE cm_result_table; - SELECT MADLIB_SCHEMA.cmsketch_centile(MADLIB_SCHEMA.cmsketch(a1),90,count(*)) INTO result2 FROM cm_data; + SELECT MADLIB_SCHEMA.cmsketch_centile(MADLIB_SCHEMA.cmsketch(a1),90,count(*)) INTO result2 FROM "CM_DATA"; IF result2 != 3 THEN RAISE EXCEPTION 'Incorrect cmsketch_centile results, got %',result2; END IF; - PERFORM MADLIB_SCHEMA.cmsketch_width_histogram(MADLIB_SCHEMA.cmsketch(a1),0,10,2) FROM cm_data; - PERFORM MADLIB_SCHEMA.cmsketch_depth_histogram(MADLIB_SCHEMA.cmsketch(a1),2) FROM cm_data; + PERFORM MADLIB_SCHEMA.cmsketch_width_histogram(MADLIB_SCHEMA.cmsketch(a1),0,10,2) FROM "CM_DATA"; + PERFORM MADLIB_SCHEMA.cmsketch_depth_histogram(MADLIB_SCHEMA.cmsketch(a1),2) FROM "CM_DATA"; -- SELECT class,fmsketch_dcount(a1) FROM cm_data GROUP BY class; -- SELECT mfvsketch_top_histogram(a1,5) FROM cm_data; http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/f1aa9af6/methods/sketch/src/pg_gp/sql/fm.sql_in ---------------------------------------------------------------------- diff --git a/methods/sketch/src/pg_gp/sql/fm.sql_in b/methods/sketch/src/pg_gp/sql/fm.sql_in index 16e5405..c367329 100644 --- a/methods/sketch/src/pg_gp/sql/fm.sql_in +++ b/methods/sketch/src/pg_gp/sql/fm.sql_in @@ -17,17 +17,17 @@ declare result2 INT; begin - -- DROP TABLE IF EXISTS fm_data; - CREATE TABLE fm_data(class INT, a1 INT); - INSERT INTO fm_data SELECT 1,1 FROM generate_series(1,10000); - INSERT INTO fm_data SELECT 1,2 FROM generate_series(1,15000); - INSERT INTO fm_data SELECT 1,3 FROM generate_series(1,10000); - INSERT INTO fm_data SELECT 2,5 FROM generate_series(1,1000); - INSERT INTO fm_data SELECT 2,6 FROM generate_series(1,1000); + -- DROP TABLE IF EXISTS "FM_DATA"; + CREATE TABLE "FM_DATA"(class INT, a1 INT); + INSERT INTO "FM_DATA" SELECT 1,1 FROM generate_series(1,10000); + INSERT INTO "FM_DATA" SELECT 1,2 FROM generate_series(1,15000); + INSERT INTO "FM_DATA" SELECT 1,3 FROM generate_series(1,10000); + INSERT INTO "FM_DATA" SELECT 2,5 FROM generate_series(1,1000); + INSERT INTO "FM_DATA" SELECT 2,6 FROM generate_series(1,1000); -- DROP TABLE IF EXISTS fm_result_table; CREATE TABLE fm_result_table AS - SELECT (fmsketch_dcount(a1)) as val FROM fm_data GROUP BY class ORDER BY class; + SELECT (fmsketch_dcount(a1)) as val FROM "FM_DATA" GROUP BY class ORDER BY class; SELECT array( SELECT val FROM fm_result_table) INTO result; IF ((result[1] + result[2]) != 5) THEN http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/f1aa9af6/methods/sketch/src/pg_gp/sql/mfv.sql_in ---------------------------------------------------------------------- diff --git a/methods/sketch/src/pg_gp/sql/mfv.sql_in b/methods/sketch/src/pg_gp/sql/mfv.sql_in index 9294f0f..d7c7dd6 100644 --- a/methods/sketch/src/pg_gp/sql/mfv.sql_in +++ b/methods/sketch/src/pg_gp/sql/mfv.sql_in @@ -12,13 +12,13 @@ --------------------------------------------------------------------------- -- Basic methods -create table mfv_test as +create table "MFV_TEST" as (select generate_series(1,10000) i union all select generate_series(10,15) i); -select mfvsketch_top_histogram(i,5) from mfv_test; +select mfvsketch_top_histogram(i,5) from "MFV_TEST"; select mfvsketch_top_histogram(utc_offset,5) from pg_timezone_names; select mfvsketch_top_histogram(NULL::bytea,5) from generate_series(1,100); -select mfvsketch_quick_histogram(i,5) from mfv_test; +select mfvsketch_quick_histogram(i,5) from "MFV_TEST"; select mfvsketch_quick_histogram(utc_offset,5) from pg_timezone_names; select mfvsketch_quick_histogram(NULL::bytea,5) from generate_series(1,100); http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/f1aa9af6/src/ports/postgres/modules/convex/test/mlp.sql_in ---------------------------------------------------------------------- diff --git a/src/ports/postgres/modules/convex/test/mlp.sql_in b/src/ports/postgres/modules/convex/test/mlp.sql_in index 2302252..e7964d2 100644 --- a/src/ports/postgres/modules/convex/test/mlp.sql_in +++ b/src/ports/postgres/modules/convex/test/mlp.sql_in @@ -29,15 +29,15 @@ SELECT setseed(0.6); -DROP TABLE IF EXISTS iris_data, iris_test, mlp_class, mlp_class_summary CASCADE; -CREATE TABLE iris_data( +DROP TABLE IF EXISTS "Iris_data", iris_test, mlp_class, mlp_class_summary CASCADE; +CREATE TABLE "Iris_data"( id integer, attributes numeric[], class_text varchar, class integer ); -INSERT INTO iris_data VALUES +INSERT INTO "Iris_data" VALUES (1,ARRAY[5.1,3.5,1.4,0.2],'Iris-setosa',1), (2,ARRAY[4.9,3.0,1.4,0.2],'Iris-setosa',1), (3,ARRAY[4.7,3.2,1.3,0.2],'Iris-setosa',1), @@ -191,7 +191,7 @@ INSERT INTO iris_data VALUES SELECT mlp_classification( - 'iris_data', -- Source table + '"Iris_data"', -- Source table 'mlp_class', -- Desination table 'attributes', -- Input features 'class', -- Label @@ -219,7 +219,7 @@ DROP TABLE IF EXISTS mlp_prediction_output; -- See prediction accuracy for training data SELECT mlp_predict( 'mlp_class', - 'iris_data', + '"Iris_data"', 'id', 'mlp_prediction_output', 'output'); @@ -231,16 +231,16 @@ SELECT assert( 'MLP: Score is too low (< 140). Wrong result.' ) FROM( SELECT SUM( -mlp_prediction_output.estimated_prob_1*(iris_data.class=1)::INT+ -mlp_prediction_output.estimated_prob_2*(iris_data.class=2)::INT+ -mlp_prediction_output.estimated_prob_3*(iris_data.class=3)::INT +mlp_prediction_output.estimated_prob_1 * ("Iris_data".class=1)::INT+ +mlp_prediction_output.estimated_prob_2 * ("Iris_data".class=2)::INT+ +mlp_prediction_output.estimated_prob_3 * ("Iris_data".class=3)::INT ) AS score -FROM mlp_prediction_output INNER JOIN iris_data ON iris_data.id=mlp_prediction_output.id)q; +FROM mlp_prediction_output INNER JOIN "Iris_data" ON "Iris_data".id=mlp_prediction_output.id)q; SELECT mlp_predict( 'mlp_class', - 'iris_data', + '"Iris_data"', 'id', 'mlp_prediction', 'response'); @@ -250,9 +250,9 @@ SELECT assert( COUNT(*)/150.0 > 0.95, 'MLP: Accuracy is too low (< 95%). Wrong result.' ) FROM - (SELECT iris_data.class AS actual, mlp_prediction.estimated_class as estimated - FROM mlp_prediction INNER JOIN iris_data ON - iris_data.id=mlp_prediction.id) q + (SELECT "Iris_data".class AS actual, mlp_prediction.estimated_class as estimated + FROM mlp_prediction INNER JOIN "Iris_data" ON + "Iris_data".id=mlp_prediction.id) q WHERE q.actual=q.estimated; DROP TABLE IF EXISTS mlp_prediction; http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/f1aa9af6/src/ports/postgres/modules/graph/test/apsp.sql_in ---------------------------------------------------------------------- diff --git a/src/ports/postgres/modules/graph/test/apsp.sql_in b/src/ports/postgres/modules/graph/test/apsp.sql_in index a7fa3af..3f7af8a 100644 --- a/src/ports/postgres/modules/graph/test/apsp.sql_in +++ b/src/ports/postgres/modules/graph/test/apsp.sql_in @@ -19,7 +19,7 @@ * *//* ----------------------------------------------------------------------- */ -DROP TABLE IF EXISTS vertex,edge,out,out_summary,out_path, +DROP TABLE IF EXISTS vertex,"EDGE",out,out_summary,out_path, vertex_alt,edge_alt,out_alt,out_alot_summary, edge_gr,out_gr,out_gr_summary,out_gr_path, edge_gr2, out_gr2, out_gr2_summary; @@ -29,9 +29,9 @@ CREATE TABLE vertex( id INTEGER ); -CREATE TABLE edge( +CREATE TABLE "EDGE"( src INTEGER, - dest INTEGER, + "DEST" INTEGER, weight DOUBLE PRECISION ); @@ -45,7 +45,7 @@ INSERT INTO vertex VALUES (6), (7) ; -INSERT INTO edge VALUES +INSERT INTO "EDGE" VALUES (0, 1, 1), (0, 2, 1), (0, 4, 10), @@ -61,39 +61,39 @@ INSERT INTO edge VALUES ; -SELECT graph_apsp('vertex',NULL,'edge',NULL,'out'); +SELECT graph_apsp('vertex',NULL,'"EDGE"','dest="DEST"','out'); -SELECT * FROM out ORDER BY src,dest; +SELECT * FROM out ORDER BY src,"DEST"; SELECT assert(weight = 4, 'Wrong output in graph (APSP)') -FROM out WHERE src = 0 AND dest = 7; +FROM out WHERE src = 0 AND "DEST" = 7; SELECT assert(parent = 6, 'Wrong parent in graph (APSP)') -FROM out WHERE src = 0 AND dest = 7; +FROM out WHERE src = 0 AND "DEST" = 7; SELECT assert(weight = 11, 'Wrong output in graph (APSP)') -FROM out WHERE src = 3 AND dest = 4; +FROM out WHERE src = 3 AND "DEST" = 4; SELECT assert(parent = 0, 'Wrong parent in graph (APSP)') -FROM out WHERE src = 3 AND dest = 4; +FROM out WHERE src = 3 AND "DEST" = 4; -- Path SELECT graph_apsp_get_path('out',0,7,'out_path'); -- Grouping CREATE TABLE edge_gr AS -(SELECT *, 0 AS grp FROM edge +(SELECT *, 0 AS grp FROM "EDGE" UNION -SELECT *, 1 AS grp FROM edge WHERE src < 6 AND dest < 6 +SELECT *, 1 AS grp FROM "EDGE" WHERE src < 6 AND "DEST" < 6 UNION -SELECT *, 2 AS grp FROM edge WHERE src < 6 AND dest < 6 +SELECT *, 2 AS grp FROM "EDGE" WHERE src < 6 AND "DEST" < 6 ); INSERT INTO edge_gr VALUES (7,NULL,NULL,1), (4,0,-20,2); -SELECT graph_apsp('vertex',NULL,'edge_gr',NULL,'out_gr','grp'); +SELECT graph_apsp('vertex',NULL,'edge_gr','dest="DEST"','out_gr','grp'); SELECT assert(weight = 2, 'Wrong output in graph (APSP)') - FROM out_gr WHERE src = 0 AND dest = 5 AND grp = 1; + FROM out_gr WHERE src = 0 AND "DEST" = 5 AND grp = 1; SELECT assert(parent = 2, 'Wrong output in graph (APSP)') - FROM out_gr WHERE src = 0 AND dest = 5 AND grp = 1; + FROM out_gr WHERE src = 0 AND "DEST" = 5 AND grp = 1; http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/f1aa9af6/src/ports/postgres/modules/graph/test/bfs.sql_in ---------------------------------------------------------------------- diff --git a/src/ports/postgres/modules/graph/test/bfs.sql_in b/src/ports/postgres/modules/graph/test/bfs.sql_in index a035eb3..d2e48c5 100644 --- a/src/ports/postgres/modules/graph/test/bfs.sql_in +++ b/src/ports/postgres/modules/graph/test/bfs.sql_in @@ -20,7 +20,7 @@ *//* ----------------------------------------------------------------------- */ -DROP TABLE IF EXISTS vertex,edge,edge_grp; +DROP TABLE IF EXISTS vertex,"EDGE",edge_grp; CREATE TABLE vertex( id INTEGER @@ -40,12 +40,12 @@ INSERT INTO vertex VALUES (11) ; -CREATE TABLE edge( - src INTEGER, +CREATE TABLE "EDGE"( + "SRC" INTEGER, dest INTEGER, weight DOUBLE PRECISION ); -INSERT INTO edge VALUES +INSERT INTO "EDGE" VALUES (0, 5, 1), (1, 0, 1), (1, 3, 1), @@ -62,7 +62,7 @@ INSERT INTO edge VALUES CREATE TABLE edge_grp( g1 INTEGER, g2 TEXT, - src INTEGER, + "SRC" INTEGER, dest INTEGER, weight DOUBLE PRECISION ); @@ -104,7 +104,7 @@ INSERT INTO edge_grp VALUES -- Results to check against - uncomment if needed -- -- source_vertex = 3 -- DROP TABLE IF EXISTS out_actual; --- CREATE TABLE out_actual (src INT, id INT, dist INT, parent INT); +-- CREATE TABLE out_actual ("SRC" INT, id INT, dist INT, parent INT); -- INSERT INTO out_actual VALUES -- (3,3,0,NULL), -- (3,1,1,3), @@ -116,11 +116,11 @@ INSERT INTO edge_grp VALUES -- ; -- -- source_vertex = 7 -- DROP TABLE IF EXISTS out_actual; --- CREATE TABLE out_actual (src INT, id INT, dist INT, parent INT); --- +-- CREATE TABLE out_actual ("SRC" INT, id INT, dist INT, parent INT); +-- -- -- source_vertex = 8 -- DROP TABLE IF EXISTS out_actual; --- CREATE TABLE out_actual (src INT, id INT, dist INT, parent INT); +-- CREATE TABLE out_actual ("SRC" INT, id INT, dist INT, parent INT); -- INSERT INTO out_actual VALUES -- (8,8,0,NULL), -- (8,9,1,8), @@ -131,29 +131,29 @@ INSERT INTO edge_grp VALUES -- Undirected graph -- source_vertex = 3 DROP TABLE IF EXISTS out_frombfs, out_frombfs_summary; -SELECT graph_bfs('vertex',NULL,'edge',NULL,3,'out_frombfs'); +SELECT graph_bfs('vertex',NULL,'"EDGE"','src="SRC"',3,'out_frombfs'); SELECT assert( (array_agg(id ORDER BY id) = ARRAY[1,4,5]::INT[]) - AND - (array_agg(parent ORDER BY id) = ARRAY[3,3,3]::INT[]), - 'Wrong output in graph (BFS)') + AND + (array_agg(parent ORDER BY id) = ARRAY[3,3,3]::INT[]), + 'Wrong output in graph (BFS)') FROM out_frombfs WHERE dist = 1 GROUP BY dist; -SELECT assert(max(dist) = 3, 'Wrong output in graph (BFS)') +SELECT assert(max(dist) = 3, 'Wrong output in graph (BFS)') FROM out_frombfs; -- source_vertex = 7 DROP TABLE IF EXISTS out_frombfs, out_frombfs_summary; -SELECT graph_bfs('vertex',NULL,'edge',NULL,7,'out_frombfs'); +SELECT graph_bfs('vertex',NULL,'"EDGE"','src="SRC"',7,'out_frombfs'); SELECT assert(COUNT(*) = 0, 'Wrong output in graph (BFS)') FROM out_frombfs; -- source_vertex = 8 DROP TABLE IF EXISTS out_frombfs, out_frombfs_summary; -SELECT graph_bfs('vertex',NULL,'edge',NULL,8,'out_frombfs',NULL,FALSE,NULL); +SELECT graph_bfs('vertex',NULL,'"EDGE"','src="SRC"',8,'out_frombfs',NULL,FALSE,NULL); -SELECT assert(parent = 8, 'Wrong output in graph (BFS)') +SELECT assert(parent = 8, 'Wrong output in graph (BFS)') FROM out_frombfs WHERE dist = 2 AND id = 10; ------------------- @@ -163,7 +163,7 @@ SELECT assert(parent = 8, 'Wrong output in graph (BFS)') -- -- source_vertex = 3 -- DROP TABLE IF EXISTS out_actual; --- CREATE TABLE out_actual (src INT, id INT, dist INT, parent INT); +-- CREATE TABLE out_actual ("SRC" INT, id INT, dist INT, parent INT); -- INSERT INTO out_actual VALUES -- (3,3,0,NULL), -- (3,4,1,3), @@ -173,10 +173,10 @@ SELECT assert(parent = 8, 'Wrong output in graph (BFS)') -- ; -- -- source_vertex = 7 -- DROP TABLE IF EXISTS out_actual; --- CREATE TABLE out_actual (src INT, id INT, dist INT, parent INT); +-- CREATE TABLE out_actual ("SRC" INT, id INT, dist INT, parent INT); -- -- source_vertex = 8 -- DROP TABLE IF EXISTS out_actual; --- CREATE TABLE out_actual (src INT, id INT, dist INT, parent INT); +-- CREATE TABLE out_actual ("SRC" INT, id INT, dist INT, parent INT); -- (8, 8, 0, NULL), -- (8, 9, 1, 8), -- (8, 10, 2, 9), @@ -185,27 +185,27 @@ SELECT assert(parent = 8, 'Wrong output in graph (BFS)') -- source_vertex = 3 DROP TABLE IF EXISTS out_frombfs, out_frombfs_summary; -SELECT graph_bfs('vertex','id','edge','src,dest',3,'out_frombfs',NULL,TRUE,NULL); +SELECT graph_bfs('vertex','id','"EDGE"','src="SRC",dest',3,'out_frombfs',NULL,TRUE,NULL); SELECT assert( (array_agg(id ORDER BY id) = ARRAY[4,5]::INT[]) - AND + AND (array_agg(parent ORDER BY id) = ARRAY[3,3]::INT[]), - 'Wrong output in graph (BFS)') + 'Wrong output in graph (BFS)') FROM out_frombfs WHERE dist = 1 GROUP BY dist; SELECT assert(COUNT(*) = 5, 'Wrong output in graph (BFS)') FROM out_frombfs; -- source_vertex = 7 DROP TABLE IF EXISTS out_frombfs, out_frombfs_summary; -SELECT graph_bfs('vertex','id','edge','src,dest',7,'out_frombfs',NULL,TRUE,NULL); +SELECT graph_bfs('vertex','id','"EDGE"','src="SRC",dest',7,'out_frombfs',NULL,TRUE,NULL); SELECT assert(COUNT(*) = 0, 'Wrong output in graph (BFS)') FROM out_frombfs; -- source_vertex = 8 DROP TABLE IF EXISTS out_frombfs, out_frombfs_summary; -SELECT graph_bfs('vertex',NULL,'edge',NULL,8,'out_frombfs',NULL,TRUE); +SELECT graph_bfs('vertex',NULL,'"EDGE"','src="SRC"',8,'out_frombfs',NULL,TRUE); -SELECT assert(COUNT(*) = 2, 'Wrong output in graph (BFS)') +SELECT assert(COUNT(*) = 2, 'Wrong output in graph (BFS)') FROM out_frombfs WHERE dist = 2; ----------------------- @@ -214,14 +214,14 @@ SELECT assert(COUNT(*) = 2, 'Wrong output in graph (BFS)') -- source_vertex = 3 -- Undirected graph DROP TABLE IF EXISTS out_frombfs, out_frombfs_summary; -SELECT graph_bfs('vertex','id','edge','src,dest',3,'out_frombfs',2,FALSE); +SELECT graph_bfs('vertex','id','"EDGE"','src="SRC",dest',3,'out_frombfs',2,FALSE); SELECT assert(MAX(dist) = 2 AND COUNT(*) = 6, 'Wrong output in graph (BFS)') FROM out_frombfs; -- Directed graph DROP TABLE IF EXISTS out_frombfs, out_frombfs_summary; -SELECT graph_bfs('vertex',NULL,'edge',NULL,3,'out_frombfs',2,TRUE); +SELECT graph_bfs('vertex',NULL,'"EDGE"','src="SRC"',3,'out_frombfs',2,TRUE); SELECT assert(MAX(dist) = 2 AND COUNT(*) = 4, 'Wrong output in graph (BFS)') FROM out_frombfs; @@ -229,10 +229,10 @@ SELECT assert(MAX(dist) = 2 AND COUNT(*) = 4, --------------------- -- Grouping columns --------------------- --- -- source_vertex = 3 +-- -- source_vertex = 3 -- -- Undirected graph -- DROP TABLE IF EXISTS out_actual; --- CREATE TABLE out_actual (src INT, id INT, dist INT, parent INT); +-- CREATE TABLE out_actual ("SRC" INT, id INT, dist INT, parent INT); -- INSERT INTO out_actual VALUES -- (3,100,'a',3,0,NULL), -- (3,100,'a',1,1,3), @@ -251,22 +251,22 @@ SELECT assert(MAX(dist) = 2 AND COUNT(*) = 4, -- ; DROP TABLE IF EXISTS out_frombfs, out_frombfs_summary; -SELECT graph_bfs('vertex',NULL,'edge_grp',NULL,3,'out_frombfs',NULL,NULL,'g1,g2'); +SELECT graph_bfs('vertex',NULL,'edge_grp','src="SRC"',3,'out_frombfs',NULL,NULL,'g1,g2'); SELECT assert( COUNT(*) = 14,'Wrong output in graph (BFS)') FROM out_frombfs; SELECT assert(COUNT(*) = 7, 'Wrong output in graph (BFS)') FROM out_frombfs WHERE g2 = 'a' ; SELECT assert( - array_agg(id ORDER BY id) = ARRAY[0,2]::INT[] - AND + array_agg(id ORDER BY id) = ARRAY[0,2]::INT[] + AND array_agg(parent ORDER BY id) = ARRAY[1,4]::INT[], 'Wrong output in graph (BFS)') FROM out_frombfs WHERE dist = 2 AND g1 = 100 AND g2 = 'a' ; SELECT assert( - array_agg(id ORDER BY id) = ARRAY[0,2]::INT[] - AND + array_agg(id ORDER BY id) = ARRAY[0,2]::INT[] + AND array_agg(parent ORDER BY id) = ARRAY[1,4]::INT[], 'Wrong output in graph (BFS)') FROM out_frombfs WHERE dist = 2 AND g1 = 100 AND g2 = 'b' http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/f1aa9af6/src/ports/postgres/modules/graph/test/measures.sql_in ---------------------------------------------------------------------- diff --git a/src/ports/postgres/modules/graph/test/measures.sql_in b/src/ports/postgres/modules/graph/test/measures.sql_in index b0bf95e..2842ffa 100644 --- a/src/ports/postgres/modules/graph/test/measures.sql_in +++ b/src/ports/postgres/modules/graph/test/measures.sql_in @@ -20,15 +20,15 @@ */ /* ----------------------------------------------------------------------- */ --- Create vertex and edge tables to represent the graph: -DROP TABLE IF EXISTS vertex, edge; +-- Create vertex and "EDGE" tables to represent the graph: +DROP TABLE IF EXISTS vertex, "EDGE"; CREATE TABLE vertex( id INTEGER, name TEXT ); -CREATE TABLE edge( +CREATE TABLE "EDGE"( src_id INTEGER, - dest_id INTEGER, + "DEST_ID" INTEGER, edge_weight FLOAT8 ); INSERT INTO vertex VALUES @@ -40,7 +40,7 @@ INSERT INTO vertex VALUES (5, 'F'), (6, 'G'), (7, 'H'); -INSERT INTO edge VALUES +INSERT INTO "EDGE" VALUES (0, 1, 1.0), (0, 2, 1.0), (0, 4, 10.0), @@ -58,9 +58,9 @@ INSERT INTO edge VALUES DROP TABLE IF EXISTS out_apsp, out_apsp_summary; SELECT graph_apsp('vertex', -- Vertex table 'id', -- Vertix id column (NULL means use default naming) - 'edge', -- Edge table - 'src=src_id, dest=dest_id, weight=edge_weight', - -- Edge arguments (NULL means use default naming) + '"EDGE"', -- "EDGE" table + 'src=src_id, dest="DEST_ID", weight=edge_weight', + -- "EDGE" arguments (NULL means use default naming) 'out_apsp'); -- Output table of shortest paths -- Compute the closeness measure for all nodes: @@ -93,9 +93,9 @@ SELECT assert(relative_error(avg_path_length, 2.0178) < 1e-2, DROP TABLE IF EXISTS out_degrees; SELECT graph_vertex_degrees('vertex', -- Vertex table 'id', -- Vertix id column (NULL means use default naming) - 'edge', -- Edge table - 'src=src_id, dest=dest_id, weight=edge_weight', - -- Edge arguments (NULL means use default naming) + '"EDGE"', -- "EDGE" table + 'src=src_id, dest="DEST_ID", weight=edge_weight', + -- "EDGE" arguments (NULL means use default naming) 'out_degrees'); SELECT * FROM out_degrees; SELECT assert(indegree = 2 and outdegree = 3, 'Invalid value for degrees') @@ -109,9 +109,9 @@ WHERE id = 0; DROP TABLE IF EXISTS edge_gr; CREATE TABLE edge_gr AS ( - SELECT *, 0 AS grp FROM edge + SELECT *, 0 AS grp FROM "EDGE" UNION - SELECT *, 1 AS grp FROM edge WHERE src_id < 6 AND dest_id < 6 + SELECT *, 1 AS grp FROM "EDGE" WHERE src_id < 6 AND "DEST_ID" < 6 ); INSERT INTO edge_gr VALUES (4,5,-20,1); @@ -120,8 +120,8 @@ INSERT INTO edge_gr VALUES DROP TABLE IF EXISTS out_apsp, out_apsp_summary; SELECT graph_apsp('vertex', -- Vertex table 'id', -- Vertex id column (NULL means use default naming) - 'edge_gr', -- Edge table - 'src=src_id, dest=dest_id, weight=edge_weight', + 'edge_gr', -- "EDGE" table + 'src=src_id, dest="DEST_ID", weight=edge_weight', 'out_apsp', -- Output table of shortest paths 'grp' -- Grouping columns ); @@ -143,8 +143,8 @@ SELECT * FROM out ORDER BY grp; DROP TABLE IF EXISTS out_degrees; SELECT graph_vertex_degrees('vertex', -- Vertex table 'id', -- Vertix id column (NULL means use default naming) - 'edge_gr', -- Edge table - 'src=src_id, dest=dest_id, weight=edge_weight', + 'edge_gr', -- "EDGE" table + 'src=src_id, dest="DEST_ID", weight=edge_weight', 'out_degrees', 'grp'); SELECT * FROM out_degrees ORDER BY grp, id; http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/f1aa9af6/src/ports/postgres/modules/graph/test/pagerank.sql_in ---------------------------------------------------------------------- diff --git a/src/ports/postgres/modules/graph/test/pagerank.sql_in b/src/ports/postgres/modules/graph/test/pagerank.sql_in index d3bc32b..e66986b 100644 --- a/src/ports/postgres/modules/graph/test/pagerank.sql_in +++ b/src/ports/postgres/modules/graph/test/pagerank.sql_in @@ -19,11 +19,11 @@ * *//* ----------------------------------------------------------------------- */ -DROP TABLE IF EXISTS vertex, edge; +DROP TABLE IF EXISTS vertex, "EDGE"; CREATE TABLE vertex( id INTEGER ); -CREATE TABLE edge( +CREATE TABLE "EDGE"( src INTEGER, dest INTEGER, user_id INTEGER @@ -36,7 +36,7 @@ INSERT INTO vertex VALUES (4), (5), (6); -INSERT INTO edge VALUES +INSERT INTO "EDGE" VALUES (0, 1, 1), (0, 2, 1), (0, 4, 1), @@ -64,8 +64,8 @@ DROP TABLE IF EXISTS pagerank_out, pagerank_out_summary; SELECT pagerank( 'vertex', -- Vertex table 'id', -- Vertix id column - 'edge', -- Edge table - 'src=src, dest=dest', -- Edge args + '"EDGE"', -- "EDGE" table + 'src=src, dest=dest', -- "EDGE" args 'pagerank_out'); -- Output table of PageRank -- View the PageRank of all vertices, sorted by their scores. @@ -78,8 +78,8 @@ DROP TABLE IF EXISTS pagerank_gr_out_summary; SELECT pagerank( 'vertex', -- Vertex table 'id', -- Vertix id column - 'edge', -- Edge table - 'src=src, dest=dest', -- Edge args + '"EDGE"', -- "EDGE" table + 'src=src, dest=dest', -- "EDGE" args 'pagerank_gr_out', -- Output table of PageRank NULL, NULL, http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/f1aa9af6/src/ports/postgres/modules/graph/test/sssp.sql_in ---------------------------------------------------------------------- diff --git a/src/ports/postgres/modules/graph/test/sssp.sql_in b/src/ports/postgres/modules/graph/test/sssp.sql_in index 621d55d..e0c3ef8 100644 --- a/src/ports/postgres/modules/graph/test/sssp.sql_in +++ b/src/ports/postgres/modules/graph/test/sssp.sql_in @@ -20,7 +20,7 @@ *//* ----------------------------------------------------------------------- */ -DROP TABLE IF EXISTS vertex,edge,out,out_summary,out_path, +DROP TABLE IF EXISTS vertex,"EDGE",out,out_summary,out_path, vertex_alt,edge_alt,out_alt,out_alot_summary, edge_gr,out_gr,out_gr_summary,out_gr_path, edge_gr2, out_gr2, out_gr2_summary, @@ -30,7 +30,7 @@ CREATE TABLE vertex( id INTEGER ); -CREATE TABLE edge( +CREATE TABLE "EDGE"( src INTEGER, dest INTEGER, weight DOUBLE PRECISION @@ -46,7 +46,7 @@ INSERT INTO vertex VALUES (6), (7) ; -INSERT INTO edge VALUES +INSERT INTO "EDGE" VALUES (0, 1, 1), (0, 2, 1), (0, 4, 10), @@ -61,7 +61,7 @@ INSERT INTO edge VALUES (6, 7, 1) ; -SELECT graph_sssp('vertex',NULL,'edge',NULL,0,'out'); +SELECT graph_sssp('vertex',NULL,'"EDGE"',NULL,0,'out'); SELECT * FROM out; @@ -75,7 +75,7 @@ SELECT graph_sssp_get_path('out',6,'out_path'); CREATE TABLE vertex_alt AS SELECT id AS v_id FROM vertex; CREATE TABLE edge_alt AS SELECT src AS e_src, dest, weight AS e_weight - FROM edge; + FROM "EDGE"; SELECT graph_sssp('vertex_alt','v_id','edge_alt','src=e_src, weight=e_weight' ,1,'out_alt'); @@ -88,11 +88,11 @@ SELECT assert(parent = 5, 'Wrong parent in graph (SSSP)') FROM out_alt WHERE v_id = 6; CREATE TABLE edge_gr AS -( SELECT *, 0 AS grp FROM edge +( SELECT *, 0 AS grp FROM "EDGE" UNION - SELECT *, 1 AS grp FROM edge WHERE src < 6 AND dest < 6 + SELECT *, 1 AS grp FROM "EDGE" WHERE src < 6 AND dest < 6 UNION - SELECT *, 2 AS grp FROM edge WHERE src < 6 AND dest < 6 + SELECT *, 2 AS grp FROM "EDGE" WHERE src < 6 AND dest < 6 ); INSERT INTO edge_gr VALUES @@ -117,11 +117,11 @@ SELECT assert(weight = 'Infinity', 'Wrong output in graph (SSSP)') SELECT graph_sssp_get_path('out_gr',5,'out_gr_path'); CREATE TABLE edge_gr2 AS -( SELECT *, 0 AS grp1, 0 AS grp2 FROM edge +( SELECT *, 0 AS grp1, 0 AS grp2 FROM "EDGE" UNION - SELECT *, 1 AS grp1, 0 AS grp2 FROM edge WHERE src < 6 AND dest < 6 + SELECT *, 1 AS grp1, 0 AS grp2 FROM "EDGE" WHERE src < 6 AND dest < 6 UNION - SELECT *, 1 AS grp1, 1 AS grp2 FROM edge WHERE src < 6 AND dest < 6 + SELECT *, 1 AS grp1, 1 AS grp2 FROM "EDGE" WHERE src < 6 AND dest < 6 ); SELECT graph_sssp('vertex',NULL,'edge_gr2',NULL,0,'out_gr2','grp1,grp2'); @@ -131,7 +131,7 @@ SELECT assert(weight = 3, 'Wrong output in graph (SSSP)') SELECT assert(parent = 5, 'Wrong parent in graph (SSSP)') FROM out_gr2 WHERE id = 6 AND grp1 = 0 AND grp2 = 0; -CREATE TABLE "edge_Q" AS SELECT src, dest AS "dest_Q", weight FROM edge; +CREATE TABLE "edge_Q" AS SELECT src, dest AS "dest_Q", weight FROM "EDGE"; SELECT graph_sssp('vertex','','"edge_Q"','dest="dest_Q"',0,'"out_Q"',''); http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/f1aa9af6/src/ports/postgres/modules/graph/test/wcc.sql_in ---------------------------------------------------------------------- diff --git a/src/ports/postgres/modules/graph/test/wcc.sql_in b/src/ports/postgres/modules/graph/test/wcc.sql_in index a943f6e..1dbb8e2 100644 --- a/src/ports/postgres/modules/graph/test/wcc.sql_in +++ b/src/ports/postgres/modules/graph/test/wcc.sql_in @@ -19,11 +19,11 @@ * *//* ----------------------------------------------------------------------- */ -DROP TABLE IF EXISTS vertex, edge; +DROP TABLE IF EXISTS vertex, "EDGE"; CREATE TABLE vertex( vertex_id INTEGER ); -CREATE TABLE edge( +CREATE TABLE "EDGE"( src_node INTEGER, dest_node INTEGER, user_id INTEGER @@ -43,7 +43,7 @@ INSERT INTO vertex VALUES (14), (15), (16); -INSERT INTO edge VALUES +INSERT INTO "EDGE" VALUES (0, 1, 1), (0, 2, 1), (1, 2, 1), @@ -67,7 +67,7 @@ DROP TABLE IF EXISTS wcc_out, wcc_out_summary; SELECT weakly_connected_components( 'vertex', 'vertex_id', - 'edge', + '"EDGE"', 'src=src_node,dest=dest_node', 'wcc_out'); @@ -75,7 +75,7 @@ SELECT assert(relative_error(count(distinct component_id), 4) < 0.00001, 'Weakly Connected Components: Number of components found is not 4.' ) FROM wcc_out; -INSERT INTO edge VALUES +INSERT INTO "EDGE" VALUES (0, 1, 2), (0, 2, 2), (1, 2, 2), @@ -99,7 +99,7 @@ DROP TABLE IF EXISTS wcc_out, wcc_out_summary; SELECT weakly_connected_components( 'vertex', 'vertex_id', - 'edge', + '"EDGE"', 'src=src_node,dest=dest_node', 'wcc_out', 'user_id'); http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/f1aa9af6/src/ports/postgres/modules/knn/test/knn.sql_in ---------------------------------------------------------------------- diff --git a/src/ports/postgres/modules/knn/test/knn.sql_in b/src/ports/postgres/modules/knn/test/knn.sql_in index 1bf6b57..e5427fd 100644 --- a/src/ports/postgres/modules/knn/test/knn.sql_in +++ b/src/ports/postgres/modules/knn/test/knn.sql_in @@ -26,12 +26,12 @@ m4_include(`SQLCommon.m4') * FIXME: Verify results * -------------------------------------------------------------------------- */ -drop table if exists knn_train_data; -create table knn_train_data ( +drop table if exists "KNN_TRAIN_DATA"; +create table "KNN_TRAIN_DATA" ( id integer, -data integer[], +"DATA" integer[], label float); -copy knn_train_data (id, data, label) from stdin delimiter '|'; +copy "KNN_TRAIN_DATA" (id, "DATA", label) from stdin delimiter '|'; 1|{1,1}|1.0 2|{2,2}|1.0 3|{3,3}|1.0 @@ -45,8 +45,8 @@ copy knn_train_data (id, data, label) from stdin delimiter '|'; drop table if exists knn_test_data; create table knn_test_data ( id integer, -data integer[]); -copy knn_test_data (id, data) from stdin delimiter '|'; +"DATA" integer[]); +copy knn_test_data (id, "DATA") from stdin delimiter '|'; 1|{2,1} 2|{2,6} 3|{15,40} @@ -55,15 +55,15 @@ copy knn_test_data (id, data) from stdin delimiter '|'; 6|{50,45} \. drop table if exists madlib_knn_result_classification; -select knn('knn_train_data','data','label','knn_test_data','data','id','madlib_knn_result_classification','c',3); +select knn('"KNN_TRAIN_DATA"','"DATA"','label','knn_test_data','"DATA"','id','madlib_knn_result_classification','c',3); select assert(array_agg(prediction order by id)='{1,1,0,1,0,0}', 'Wrong output in classification with k=3') from madlib_knn_result_classification; drop table if exists madlib_knn_result_regression; -select knn('knn_train_data','data','label','knn_test_data','data','id','madlib_knn_result_regression','r',4); +select knn('"KNN_TRAIN_DATA"','"DATA"','label','knn_test_data','"DATA"','id','madlib_knn_result_regression','r',4); select assert(array_agg(prediction order by id)='{1,1,0.5,1,0.25,0.25}', 'Wrong output in regression') from madlib_knn_result_regression; drop table if exists madlib_knn_result_classification; -select knn('knn_train_data','data','label','knn_test_data','data','id','madlib_knn_result_classification','c'); +select knn('"KNN_TRAIN_DATA"','"DATA"','label','knn_test_data','"DATA"','id','madlib_knn_result_classification','c'); select assert(array_agg(prediction order by id)='{1,1,0,1,0,0}', 'Wrong output in classification with k=1') from madlib_knn_result_classification; select knn(); http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/f1aa9af6/src/ports/postgres/modules/sample/test/stratified_sample.sql_in ---------------------------------------------------------------------- diff --git a/src/ports/postgres/modules/sample/test/stratified_sample.sql_in b/src/ports/postgres/modules/sample/test/stratified_sample.sql_in index 6ddcbfd..f742d01 100644 --- a/src/ports/postgres/modules/sample/test/stratified_sample.sql_in +++ b/src/ports/postgres/modules/sample/test/stratified_sample.sql_in @@ -19,16 +19,16 @@ * *//* ----------------------------------------------------------------------- */ -DROP TABLE IF EXISTS test; +DROP TABLE IF EXISTS "TEST"; -CREATE TABLE test( +CREATE TABLE "TEST"( id1 INTEGER, - id2 INTEGER, + "ID2" INTEGER, gr1 INTEGER, gr2 INTEGER ); -INSERT INTO test VALUES +INSERT INTO "TEST" VALUES (1,0,1,1), (2,0,1,1), (3,0,1,1), @@ -57,19 +57,19 @@ INSERT INTO test VALUES ; DROP TABLE IF EXISTS out; -SELECT stratified_sample('test', 'out', 0.5, NULL, 'id1,id2,gr1,gr2', FALSE); +SELECT stratified_sample('"TEST"', 'out', 0.5, NULL, 'id1,"ID2",gr1,gr2', FALSE); SELECT assert(count(*) = 13, 'Wrong number of samples') FROM out; DROP TABLE IF EXISTS out; -SELECT stratified_sample('test', 'out', 0.5, 'gr1,gr2', 'id1,id2', FALSE); +SELECT stratified_sample('"TEST"', 'out', 0.5, 'gr1,gr2', 'id1,"ID2"', FALSE); SELECT assert(count(*) = 3, 'Wrong number of samples') -FROM (SELECT DISTINCT id1,id2 FROM out WHERE gr1 = 1 AND gr2 = 2)x; +FROM (SELECT DISTINCT id1,"ID2" FROM out WHERE gr1 = 1 AND gr2 = 2)x; DROP TABLE IF EXISTS out; -SELECT stratified_sample('test', 'out', 0.5, NULL, 'id1,id2,gr1,gr2', TRUE); +SELECT stratified_sample('"TEST"', 'out', 0.5, NULL, 'id1,"ID2",gr1,gr2', TRUE); SELECT assert(count(*) = 13, 'Wrong number of samples') FROM out; DROP TABLE IF EXISTS out; -SELECT stratified_sample('test', 'out', 0.5, 'gr1,gr2', 'id1,id2', TRUE); +SELECT stratified_sample('"TEST"', 'out', 0.5, 'gr1,gr2', 'id1,"ID2"', TRUE); SELECT assert(count(*) = 6, 'Wrong number of samples') FROM out WHERE gr1 = 1 AND gr2 = 1; http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/f1aa9af6/src/ports/postgres/modules/utilities/test/pivot.sql_in ---------------------------------------------------------------------- diff --git a/src/ports/postgres/modules/utilities/test/pivot.sql_in b/src/ports/postgres/modules/utilities/test/pivot.sql_in index 3dafd18..fb034e7 100644 --- a/src/ports/postgres/modules/utilities/test/pivot.sql_in +++ b/src/ports/postgres/modules/utilities/test/pivot.sql_in @@ -19,15 +19,15 @@ * *//* ----------------------------------------------------------------------- */ -DROP TABLE IF EXISTS pivset; +DROP TABLE IF EXISTS "PIVSET"; -CREATE TABLE pivset( +CREATE TABLE "PIVSET"( id INTEGER, piv INTEGER, val INTEGER ); -INSERT INTO pivset VALUES +INSERT INTO "PIVSET" VALUES (0, 10, 1), (0, 10, 2), (0, 20, 3), @@ -40,7 +40,7 @@ INSERT INTO pivset VALUES (0, 10, NULL); DROP TABLE IF EXISTS pivout; -SELECT pivot('pivset', 'pivout', 'id', 'piv', 'val'); +SELECT pivot('"PIVSET"', 'pivout', 'id', 'piv', 'val'); SELECT * FROM pivout; SELECT assert(val_avg_piv_20 = 3, 'Wrong output in pivoting') FROM pivout WHERE id = 0; @@ -48,10 +48,10 @@ SELECT assert(val_avg_piv_20 = 3, 'Wrong output in pivoting') FROM pivout WHERE DROP VIEW IF EXISTS pivset_ext; CREATE VIEW pivset_ext AS SELECT *, - COALESCE(id + (pivset.val / 3), 0) AS id2, - COALESCE(piv + (pivset.val / 3), 0) AS piv2, + COALESCE(id + ("PIVSET".val / 3), 0) AS id2, + COALESCE(piv + ("PIVSET".val / 3), 0) AS piv2, COALESCE(val + 10, 0) AS val2 - FROM pivset; + FROM "PIVSET"; SELECT id,id2,piv,piv2,val,val2 FROM pivset_ext ORDER BY id,id2,piv,piv2,val,val2; http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/f1aa9af6/src/ports/postgres/modules/utilities/test/sessionize.sql_in ---------------------------------------------------------------------- diff --git a/src/ports/postgres/modules/utilities/test/sessionize.sql_in b/src/ports/postgres/modules/utilities/test/sessionize.sql_in index 845e572..808970c 100644 --- a/src/ports/postgres/modules/utilities/test/sessionize.sql_in +++ b/src/ports/postgres/modules/utilities/test/sessionize.sql_in @@ -88,7 +88,10 @@ SELECT sessionize( SELECT assert( - relative_error(array_agg(CASE WHEN original_session_id NOTNULL THEN original_session_id ELSE 0 END), array_agg(CASE WHEN session_id NOTNULL THEN session_id ELSE 0 END)) < 1e-6, + relative_error(array_agg(CASE WHEN original_session_id NOTNULL + THEN original_session_id ELSE 0 END), + array_agg(CASE WHEN session_id NOTNULL + THEN session_id ELSE 0 END)) < 1e-6, 'wrong output in sessionization') FROM sessionize_output_v; SELECT * FROM sessionize_output_v; @@ -105,7 +108,8 @@ SELECT sessionize( SELECT assert( - relative_error(array_agg(CASE WHEN eventlog_installchk.part_expr THEN 1 ELSE 0 END), array_agg(CASE WHEN sessionize_output_t.uid THEN 1 ELSE 0 END)) != 0, + relative_error(array_agg(CASE WHEN eventlog_installchk.part_expr THEN 1 ELSE 0 END), + array_agg(CASE WHEN sessionize_output_t.uid THEN 1 ELSE 0 END)) != 0, 'wrong output in sessionization') FROM sessionize_output_t, eventlog_installchk; SELECT * FROM sessionize_output_t;
