mirror of https://github.com/citusdata/citus.git
Make columnar_chunk_filtering pass consecutive runs (#8147)
Test was not cleaning up after itself therefore failed consecutive runs Test locally with: make check-columnar-minimal \ EXTRA_TESTS='columnar_chunk_filtering columnar_chunk_filtering'pull/8152/head
parent
439870f3a9
commit
aaa31376e0
|
|
@ -10,6 +10,8 @@
|
||||||
-- If chunks get filtered by columnar, less rows are passed to WHERE
|
-- If chunks get filtered by columnar, less rows are passed to WHERE
|
||||||
-- clause, so this function should return a lower number.
|
-- clause, so this function should return a lower number.
|
||||||
--
|
--
|
||||||
|
CREATE SCHEMA columnar_chunk_filtering;
|
||||||
|
SET search_path TO columnar_chunk_filtering, public;
|
||||||
CREATE OR REPLACE FUNCTION filtered_row_count (query text) RETURNS bigint AS
|
CREATE OR REPLACE FUNCTION filtered_row_count (query text) RETURNS bigint AS
|
||||||
$$
|
$$
|
||||||
DECLARE
|
DECLARE
|
||||||
|
|
@ -1141,4 +1143,6 @@ SELECT * FROM pushdown_test WHERE country IN ('USA', 'ZW', volatileFunction());
|
||||||
8 | ZW
|
8 | ZW
|
||||||
(3 rows)
|
(3 rows)
|
||||||
|
|
||||||
DROP TABLE pushdown_test;
|
SET client_min_messages TO WARNING;
|
||||||
|
DROP SCHEMA columnar_chunk_filtering CASCADE;
|
||||||
|
RESET client_min_messages;
|
||||||
|
|
|
||||||
|
|
@ -10,6 +10,8 @@
|
||||||
-- If chunks get filtered by columnar, less rows are passed to WHERE
|
-- If chunks get filtered by columnar, less rows are passed to WHERE
|
||||||
-- clause, so this function should return a lower number.
|
-- clause, so this function should return a lower number.
|
||||||
--
|
--
|
||||||
|
CREATE SCHEMA columnar_chunk_filtering;
|
||||||
|
SET search_path TO columnar_chunk_filtering, public;
|
||||||
CREATE OR REPLACE FUNCTION filtered_row_count (query text) RETURNS bigint AS
|
CREATE OR REPLACE FUNCTION filtered_row_count (query text) RETURNS bigint AS
|
||||||
$$
|
$$
|
||||||
DECLARE
|
DECLARE
|
||||||
|
|
@ -1141,4 +1143,6 @@ SELECT * FROM pushdown_test WHERE country IN ('USA', 'ZW', volatileFunction());
|
||||||
8 | ZW
|
8 | ZW
|
||||||
(3 rows)
|
(3 rows)
|
||||||
|
|
||||||
DROP TABLE pushdown_test;
|
SET client_min_messages TO WARNING;
|
||||||
|
DROP SCHEMA columnar_chunk_filtering CASCADE;
|
||||||
|
RESET client_min_messages;
|
||||||
|
|
|
||||||
|
|
@ -12,6 +12,10 @@
|
||||||
-- If chunks get filtered by columnar, less rows are passed to WHERE
|
-- If chunks get filtered by columnar, less rows are passed to WHERE
|
||||||
-- clause, so this function should return a lower number.
|
-- clause, so this function should return a lower number.
|
||||||
--
|
--
|
||||||
|
|
||||||
|
CREATE SCHEMA columnar_chunk_filtering;
|
||||||
|
SET search_path TO columnar_chunk_filtering, public;
|
||||||
|
|
||||||
CREATE OR REPLACE FUNCTION filtered_row_count (query text) RETURNS bigint AS
|
CREATE OR REPLACE FUNCTION filtered_row_count (query text) RETURNS bigint AS
|
||||||
$$
|
$$
|
||||||
DECLARE
|
DECLARE
|
||||||
|
|
@ -493,4 +497,6 @@ SELECT * FROM pushdown_test WHERE country IN ('USA', 'ZW', volatileFunction());
|
||||||
|
|
||||||
SELECT * FROM pushdown_test WHERE country IN ('USA', 'ZW', volatileFunction());
|
SELECT * FROM pushdown_test WHERE country IN ('USA', 'ZW', volatileFunction());
|
||||||
|
|
||||||
DROP TABLE pushdown_test;
|
SET client_min_messages TO WARNING;
|
||||||
|
DROP SCHEMA columnar_chunk_filtering CASCADE;
|
||||||
|
RESET client_min_messages;
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue