NotificationsYou must be signed in to change notification settings
Fork23
Star163

Commit5801fb0

committed

Implement is_null/is_not_null functions

1 parent1ea1934 commit5801fb0Copy full SHA for 5801fb0

File tree

5 files changed

+182

-46

lines changed

5 files changed

+182

-46

lines changed

`‎Makefile`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -6,9 +6,9 @@ OBJS = vops.o`
`6`	`6`	`EXTENSION = vops`
`7`	`7`	`DATA = vops--1.0.sql`
`8`	`8`	`PGFILEDESC = "vops - vectorized operations"`
`9`		`-CUSTOM_COPT = -O3`
	`9`	`+#CUSTOM_COPT = -O3`
`10`	`10`
`11`		`-REGRESS =`
	`11`	`+REGRESS =test.sql`
`12`	`12`
`13`	`13`	`ifdefUSE_PGXS`
`14`	`14`	`PG_CONFIG = pg_config`

`‎sql/test.out`

Lines changed: 51 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,51 @@`
	`1`	`+CREATE EXTENSION`
	`2`	`+CREATE TABLE`
	`3`	`+CREATE TABLE`
	`4`	`+INSERT 0 6`
	`5`	`+ populate`
	`6`	`+----------`
	`7`	`+`
	`8`	`+(1 row)`
	`9`	`+`
	`10`	`+ unnest`
	`11`	`+--------`
	`12`	`+ (2)`
	`13`	`+ (3)`
	`14`	`+ (4)`
	`15`	`+(3 rows)`
	`16`	`+`
	`17`	`+ countall`
	`18`	`+----------`
	`19`	`+ 4`
	`20`	`+(1 row)`
	`21`	`+`
	`22`	`+ count`
	`23`	`+-------`
	`24`	`+ 60`
	`25`	`+(1 row)`
	`26`	`+`
	`27`	`+ count`
	`28`	`+-------`
	`29`	`+ 4`
	`30`	`+(1 row)`
	`31`	`+`
	`32`	`+ count \| count \| sum \| avg \| min \| max \| variance \| var_pop \| var_samp \| stddev \| stddev_pop \| stddev_samp`
	`33`	`+-------+-------+-----+-----+-----+-----+------------------+---------+------------------+------------------+------------------+------------------`
	`34`	`+ 4 \| 4 \| 10 \| 2.5 \| 1 \| 4 \| 1.66666666666667 \| 1.25 \| 1.66666666666667 \| 1.29099444873581 \| 1.11803398874989 \| 1.29099444873581`
	`35`	`+(1 row)`
	`36`	`+`
	`37`	`+ count \| count \| sum \| avg \| min \| max \| variance \| var_pop \| var_samp \| stddev \| stddev_pop \| stddev_samp`
	`38`	`+-------+-------+-----+-----+-----+-----+------------------+---------+------------------+------------------+------------------+------------------`
	`39`	`+ 4 \| 4 \| 10 \| 2.5 \| 1 \| 4 \| 1.66666666666667 \| 1.25 \| 1.66666666666667 \| 1.29099444873581 \| 1.11803398874989 \| 1.29099444873581`
	`40`	`+(1 row)`
	`41`	`+`
	`42`	`+ count \| count \| sum \| avg \| min \| max \| variance \| var_pop \| var_samp \| stddev \| stddev_pop \| stddev_samp`
	`43`	`+-------+-------+-----+-----+-----+-----+----------+-------------------+----------+--------+-------------------+-------------`
	`44`	`+ 3 \| 3 \| 9 \| 3 \| 2 \| 4 \| 1 \| 0.666666666666667 \| 1 \| 1 \| 0.816496580927726 \| 1`
	`45`	`+(1 row)`
	`46`	`+`
	`47`	`+ count \| count \| sum \| avg \| min \| max \| variance \| var_pop \| var_samp \| stddev \| stddev_pop \| stddev_samp`
	`48`	`+-------+-------+-----+-----+-----+-----+----------+-------------------+----------+--------+-------------------+-------------`
	`49`	`+ 3 \| 3 \| 9 \| 3 \| 2 \| 4 \| 1 \| 0.666666666666667 \| 1 \| 1 \| 0.816496580927726 \| 1`
	`50`	`+(1 row)`
	`51`	`+`

`‎sql/test.sql`

Lines changed: 13 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,13 @@`
	`1`	`+create extension vops;`
	`2`	`+createtables(xreal);`
	`3`	`+createtablev(x vops_float4);`
	`4`	`+insert into svalues(1.0),(2.0),(null),(3.0),(null),(4.0);`
	`5`	`+select populate(destination:='v'::regclass, source:='s'::regclass);`
	`6`	`+select unnest(v.*)from vwhere x>1;`
	`7`	`+select countall(*)from vwhere xis not null;`
	`8`	`+selectcount(*)from vwhere x isnull;`
	`9`	`+selectcount(*)from vwhere xis not null;`
	`10`	`+selectcount(*),count(x),sum(x),avg(x),min(x),max(x),variance(x),var_pop(x),var_samp(x),stddev(x),stddev_pop(x),stddev_samp(x)from vwhere x>=0.0;`
	`11`	`+selectcount(*),count(x),sum(x),avg(x),min(x),max(x),variance(x),var_pop(x),var_samp(x),stddev(x),stddev_pop(x),stddev_samp(x)from swhere x>=0.0;`
	`12`	`+selectcount(*),count(x),sum(x),avg(x),min(x),max(x),variance(x),var_pop(x),var_samp(x),stddev(x),stddev_pop(x),stddev_samp(x)from vwhere x>1.0;`
	`13`	`+selectcount(*),count(x),sum(x),avg(x),min(x),max(x),variance(x),var_pop(x),var_samp(x),stddev(x),stddev_pop(x),stddev_samp(x)from swhere x>1.0;`

`‎vops--1.0.sql`

Lines changed: 27 additions & 24 deletions

Original file line number	Diff line number	Diff line change
`@@ -260,7 +260,7 @@ CREATE AGGREGATE variance(vops_char) (`
`260`	`260`	`CREATEAGGREGATEstddev_pop(vops_char) (`
`261`	`261`	`SFUNC= vops_char_var_accumulate,`
`262`	`262`	`STYPE= internal,`
`263`		`-FINALFUNC=vops_var_pop_final,`
	`263`	`+FINALFUNC=vops_stddev_pop_final,`
`264`	`264`	`COMBINEFUNC= vops_var_combine,`
`265`	`265`	`SERIALFUNC= vops_var_serial,`
`266`	`266`	`DESERIALFUNC= vops_var_deserial,`
`@@ -270,7 +270,7 @@ CREATE AGGREGATE stddev_pop(vops_char) (`
`270`	`270`	`CREATEAGGREGATEstddev_samp(vops_char) (`
`271`	`271`	`SFUNC= vops_char_var_accumulate,`
`272`	`272`	`STYPE= internal,`
`273`		`-FINALFUNC=vops_var_samp_final,`
	`273`	`+FINALFUNC=vops_stddev_samp_final,`
`274`	`274`	`COMBINEFUNC= vops_var_combine,`
`275`	`275`	`SERIALFUNC= vops_var_serial,`
`276`	`276`	`DESERIALFUNC= vops_var_deserial,`
`@@ -280,7 +280,7 @@ CREATE AGGREGATE stddev_samp(vops_char) (`
`280`	`280`	`CREATEAGGREGATEstddev(vops_char) (`
`281`	`281`	`SFUNC= vops_char_var_accumulate,`
`282`	`282`	`STYPE= internal,`
`283`		`-FINALFUNC=vops_var_samp_final,`
	`283`	`+FINALFUNC=vops_stddev_samp_final,`
`284`	`284`	`COMBINEFUNC= vops_var_combine,`
`285`	`285`	`SERIALFUNC= vops_var_serial,`
`286`	`286`	`DESERIALFUNC= vops_var_deserial,`
`@@ -447,7 +447,7 @@ CREATE AGGREGATE variance(vops_int2) (`
`447`	`447`	`CREATEAGGREGATEstddev_pop(vops_int2) (`
`448`	`448`	`SFUNC= vops_int2_var_accumulate,`
`449`	`449`	`STYPE= internal,`
`450`		`-FINALFUNC=vops_var_pop_final,`
	`450`	`+FINALFUNC=vops_stddev_pop_final,`
`451`	`451`	`COMBINEFUNC= vops_var_combine,`
`452`	`452`	`SERIALFUNC= vops_var_serial,`
`453`	`453`	`DESERIALFUNC= vops_var_deserial,`
`@@ -457,7 +457,7 @@ CREATE AGGREGATE stddev_pop(vops_int2) (`
`457`	`457`	`CREATEAGGREGATEstddev_samp(vops_int2) (`
`458`	`458`	`SFUNC= vops_int2_var_accumulate,`
`459`	`459`	`STYPE= internal,`
`460`		`-FINALFUNC=vops_var_samp_final,`
	`460`	`+FINALFUNC=vops_stddev_samp_final,`
`461`	`461`	`COMBINEFUNC= vops_var_combine,`
`462`	`462`	`SERIALFUNC= vops_var_serial,`
`463`	`463`	`DESERIALFUNC= vops_var_deserial,`
`@@ -467,7 +467,7 @@ CREATE AGGREGATE stddev_samp(vops_int2) (`
`467`	`467`	`CREATEAGGREGATEstddev(vops_int2) (`
`468`	`468`	`SFUNC= vops_int2_var_accumulate,`
`469`	`469`	`STYPE= internal,`
`470`		`-FINALFUNC=vops_var_samp_final,`
	`470`	`+FINALFUNC=vops_stddev_samp_final,`
`471`	`471`	`COMBINEFUNC= vops_var_combine,`
`472`	`472`	`SERIALFUNC= vops_var_serial,`
`473`	`473`	`DESERIALFUNC= vops_var_deserial,`
`@@ -648,7 +648,7 @@ CREATE AGGREGATE variance(vops_int4) (`
`648`	`648`	`CREATEAGGREGATEstddev_pop(vops_int4) (`
`649`	`649`	`SFUNC= vops_int4_var_accumulate,`
`650`	`650`	`STYPE= internal,`
`651`		`-FINALFUNC=vops_var_pop_final,`
	`651`	`+FINALFUNC=vops_stddev_pop_final,`
`652`	`652`	`COMBINEFUNC= vops_var_combine,`
`653`	`653`	`SERIALFUNC= vops_var_serial,`
`654`	`654`	`DESERIALFUNC= vops_var_deserial,`
`@@ -658,7 +658,7 @@ CREATE AGGREGATE stddev_pop(vops_int4) (`
`658`	`658`	`CREATEAGGREGATEstddev_samp(vops_int4) (`
`659`	`659`	`SFUNC= vops_int4_var_accumulate,`
`660`	`660`	`STYPE= internal,`
`661`		`-FINALFUNC=vops_var_samp_final,`
	`661`	`+FINALFUNC=vops_stddev_samp_final,`
`662`	`662`	`COMBINEFUNC= vops_var_combine,`
`663`	`663`	`SERIALFUNC= vops_var_serial,`
`664`	`664`	`DESERIALFUNC= vops_var_deserial,`
`@@ -668,7 +668,7 @@ CREATE AGGREGATE stddev_samp(vops_int4) (`
`668`	`668`	`CREATEAGGREGATEstddev(vops_int4) (`
`669`	`669`	`SFUNC= vops_int4_var_accumulate,`
`670`	`670`	`STYPE= internal,`
`671`		`-FINALFUNC=vops_var_samp_final,`
	`671`	`+FINALFUNC=vops_stddev_samp_final,`
`672`	`672`	`COMBINEFUNC= vops_var_combine,`
`673`	`673`	`SERIALFUNC= vops_var_serial,`
`674`	`674`	`DESERIALFUNC= vops_var_deserial,`
`@@ -845,7 +845,7 @@ CREATE AGGREGATE variance(vops_date) (`
`845`	`845`	`CREATEAGGREGATEstddev_pop(vops_date) (`
`846`	`846`	`SFUNC= vops_date_var_accumulate,`
`847`	`847`	`STYPE= internal,`
`848`		`-FINALFUNC=vops_var_pop_final,`
	`848`	`+FINALFUNC=vops_stddev_pop_final,`
`849`	`849`	`COMBINEFUNC= vops_var_combine,`
`850`	`850`	`SERIALFUNC= vops_var_serial,`
`851`	`851`	`DESERIALFUNC= vops_var_deserial,`
`@@ -855,7 +855,7 @@ CREATE AGGREGATE stddev_pop(vops_date) (`
`855`	`855`	`CREATEAGGREGATEstddev_samp(vops_date) (`
`856`	`856`	`SFUNC= vops_date_var_accumulate,`
`857`	`857`	`STYPE= internal,`
`858`		`-FINALFUNC=vops_var_samp_final,`
	`858`	`+FINALFUNC=vops_stddev_samp_final,`
`859`	`859`	`COMBINEFUNC= vops_var_combine,`
`860`	`860`	`SERIALFUNC= vops_var_serial,`
`861`	`861`	`DESERIALFUNC= vops_var_deserial,`
`@@ -865,7 +865,7 @@ CREATE AGGREGATE stddev_samp(vops_date) (`
`865`	`865`	`CREATEAGGREGATEstddev(vops_date) (`
`866`	`866`	`SFUNC= vops_date_var_accumulate,`
`867`	`867`	`STYPE= internal,`
`868`		`-FINALFUNC=vops_var_samp_final,`
	`868`	`+FINALFUNC=vops_stddev_samp_final,`
`869`	`869`	`COMBINEFUNC= vops_var_combine,`
`870`	`870`	`SERIALFUNC= vops_var_serial,`
`871`	`871`	`DESERIALFUNC= vops_var_deserial,`
`@@ -1042,7 +1042,7 @@ CREATE AGGREGATE variance(vops_timestamp) (`
`1042`	`1042`	`CREATEAGGREGATEstddev_pop(vops_timestamp) (`
`1043`	`1043`	`SFUNC= vops_timestamp_var_accumulate,`
`1044`	`1044`	`STYPE= internal,`
`1045`		`-FINALFUNC=vops_var_pop_final,`
	`1045`	`+FINALFUNC=vops_stddev_pop_final,`
`1046`	`1046`	`COMBINEFUNC= vops_var_combine,`
`1047`	`1047`	`SERIALFUNC= vops_var_serial,`
`1048`	`1048`	`DESERIALFUNC= vops_var_deserial,`
`@@ -1052,7 +1052,7 @@ CREATE AGGREGATE stddev_pop(vops_timestamp) (`
`1052`	`1052`	`CREATEAGGREGATEstddev_samp(vops_timestamp) (`
`1053`	`1053`	`SFUNC= vops_timestamp_var_accumulate,`
`1054`	`1054`	`STYPE= internal,`
`1055`		`-FINALFUNC=vops_var_samp_final,`
	`1055`	`+FINALFUNC=vops_stddev_samp_final,`
`1056`	`1056`	`COMBINEFUNC= vops_var_combine,`
`1057`	`1057`	`SERIALFUNC= vops_var_serial,`
`1058`	`1058`	`DESERIALFUNC= vops_var_deserial,`
`@@ -1062,7 +1062,7 @@ CREATE AGGREGATE stddev_samp(vops_timestamp) (`
`1062`	`1062`	`CREATEAGGREGATEstddev(vops_timestamp) (`
`1063`	`1063`	`SFUNC= vops_timestamp_var_accumulate,`
`1064`	`1064`	`STYPE= internal,`
`1065`		`-FINALFUNC=vops_var_samp_final,`
	`1065`	`+FINALFUNC=vops_stddev_samp_final,`
`1066`	`1066`	`COMBINEFUNC= vops_var_combine,`
`1067`	`1067`	`SERIALFUNC= vops_var_serial,`
`1068`	`1068`	`DESERIALFUNC= vops_var_deserial,`
`@@ -1240,7 +1240,7 @@ CREATE AGGREGATE variance(vops_int8) (`
`1240`	`1240`	`CREATEAGGREGATEstddev_pop(vops_int8) (`
`1241`	`1241`	`SFUNC= vops_int8_var_accumulate,`
`1242`	`1242`	`STYPE= internal,`
`1243`		`-FINALFUNC=vops_var_pop_final,`
	`1243`	`+FINALFUNC=vops_stddev_pop_final,`
`1244`	`1244`	`COMBINEFUNC= vops_var_combine,`
`1245`	`1245`	`SERIALFUNC= vops_var_serial,`
`1246`	`1246`	`DESERIALFUNC= vops_var_deserial,`
`@@ -1250,7 +1250,7 @@ CREATE AGGREGATE stddev_pop(vops_int8) (`
`1250`	`1250`	`CREATEAGGREGATEstddev_samp(vops_int8) (`
`1251`	`1251`	`SFUNC= vops_int8_var_accumulate,`
`1252`	`1252`	`STYPE= internal,`
`1253`		`-FINALFUNC=vops_var_samp_final,`
	`1253`	`+FINALFUNC=vops_stddev_samp_final,`
`1254`	`1254`	`COMBINEFUNC= vops_var_combine,`
`1255`	`1255`	`SERIALFUNC= vops_var_serial,`
`1256`	`1256`	`DESERIALFUNC= vops_var_deserial,`
`@@ -1260,7 +1260,7 @@ CREATE AGGREGATE stddev_samp(vops_int8) (`
`1260`	`1260`	`CREATEAGGREGATEstddev(vops_int8) (`
`1261`	`1261`	`SFUNC= vops_int8_var_accumulate,`
`1262`	`1262`	`STYPE= internal,`
`1263`		`-FINALFUNC=vops_var_samp_final,`
	`1263`	`+FINALFUNC=vops_stddev_samp_final,`
`1264`	`1264`	`COMBINEFUNC= vops_var_combine,`
`1265`	`1265`	`SERIALFUNC= vops_var_serial,`
`1266`	`1266`	`DESERIALFUNC= vops_var_deserial,`
`@@ -1427,7 +1427,7 @@ CREATE AGGREGATE variance(vops_float4) (`
`1427`	`1427`	`CREATEAGGREGATEstddev_pop(vops_float4) (`
`1428`	`1428`	`SFUNC= vops_float4_var_accumulate,`
`1429`	`1429`	`STYPE= internal,`
`1430`		`-FINALFUNC=vops_var_pop_final,`
	`1430`	`+FINALFUNC=vops_stddev_pop_final,`
`1431`	`1431`	`COMBINEFUNC= vops_var_combine,`
`1432`	`1432`	`SERIALFUNC= vops_var_serial,`
`1433`	`1433`	`DESERIALFUNC= vops_var_deserial,`
`@@ -1437,7 +1437,7 @@ CREATE AGGREGATE stddev_pop(vops_float4) (`
`1437`	`1437`	`CREATEAGGREGATEstddev_samp(vops_float4) (`
`1438`	`1438`	`SFUNC= vops_float4_var_accumulate,`
`1439`	`1439`	`STYPE= internal,`
`1440`		`-FINALFUNC=vops_var_samp_final,`
	`1440`	`+FINALFUNC=vops_stddev_samp_final,`
`1441`	`1441`	`COMBINEFUNC= vops_var_combine,`
`1442`	`1442`	`SERIALFUNC= vops_var_serial,`
`1443`	`1443`	`DESERIALFUNC= vops_var_deserial,`
`@@ -1447,7 +1447,7 @@ CREATE AGGREGATE stddev_samp(vops_float4) (`
`1447`	`1447`	`CREATEAGGREGATEstddev(vops_float4) (`
`1448`	`1448`	`SFUNC= vops_float4_var_accumulate,`
`1449`	`1449`	`STYPE= internal,`
`1450`		`-FINALFUNC=vops_var_samp_final,`
	`1450`	`+FINALFUNC=vops_stddev_samp_final,`
`1451`	`1451`	`COMBINEFUNC= vops_var_combine,`
`1452`	`1452`	`SERIALFUNC= vops_var_serial,`
`1453`	`1453`	`DESERIALFUNC= vops_var_deserial,`
`@@ -1614,7 +1614,7 @@ CREATE AGGREGATE variance(vops_float8) (`
`1614`	`1614`	`CREATEAGGREGATEstddev_pop(vops_float8) (`
`1615`	`1615`	`SFUNC= vops_float8_var_accumulate,`
`1616`	`1616`	`STYPE= internal,`
`1617`		`-FINALFUNC=vops_var_pop_final,`
	`1617`	`+FINALFUNC=vops_stddev_pop_final,`
`1618`	`1618`	`COMBINEFUNC= vops_var_combine,`
`1619`	`1619`	`SERIALFUNC= vops_var_serial,`
`1620`	`1620`	`DESERIALFUNC= vops_var_deserial,`
`@@ -1624,7 +1624,7 @@ CREATE AGGREGATE stddev_pop(vops_float8) (`
`1624`	`1624`	`CREATEAGGREGATEstddev_samp(vops_float8) (`
`1625`	`1625`	`SFUNC= vops_float8_var_accumulate,`
`1626`	`1626`	`STYPE= internal,`
`1627`		`-FINALFUNC=vops_var_samp_final,`
	`1627`	`+FINALFUNC=vops_stddev_samp_final,`
`1628`	`1628`	`COMBINEFUNC= vops_var_combine,`
`1629`	`1629`	`SERIALFUNC= vops_var_serial,`
`1630`	`1630`	`DESERIALFUNC= vops_var_deserial,`
`@@ -1634,7 +1634,7 @@ CREATE AGGREGATE stddev_samp(vops_float8) (`
`1634`	`1634`	`CREATEAGGREGATEstddev(vops_float8) (`
`1635`	`1635`	`SFUNC= vops_float8_var_accumulate,`
`1636`	`1636`	`STYPE= internal,`
`1637`		`-FINALFUNC=vops_var_samp_final,`
	`1637`	`+FINALFUNC=vops_stddev_samp_final,`
`1638`	`1638`	`COMBINEFUNC= vops_var_combine,`
`1639`	`1639`	`SERIALFUNC= vops_var_serial,`
`1640`	`1640`	`DESERIALFUNC= vops_var_deserial,`
`@@ -1716,3 +1716,6 @@ create function reduce(bigint) returns setof vops_aggregates as 'MODULE_PATHNAME`
`1716`	`1716`	`createfunctionunnest(anyelement) returns setof recordas'MODULE_PATHNAME','vops_unnest' language C parallel safe strict immutable;`
`1717`	`1717`
`1718`	`1718`	`create cast (vops_boolas bool) with function filter(vops_bool)AS IMPLICIT;`
	`1719`	`+`
	`1720`	`+createfunctionis_null(anyelement) returns vops_boolas'MODULE_PATHNAME','vops_is_null' language C parallel safe immutable;`
	`1721`	`+createfunctionis_not_null(anyelement) returns vops_boolas'MODULE_PATHNAME','vops_is_not_null' language C parallel safe immutable;`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit5801fb0

File tree

5 files changed

5 files changed

`‎Makefile`

`‎sql/test.out`

`‎sql/test.sql`

`‎vops--1.0.sql`

0 commit comments