hawq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From iw...@apache.org
Subject incubator-hawq git commit: HAWQ-452. Remove the workfile views from hawq_toolkit
Date Thu, 10 Mar 2016 01:16:20 GMT
Repository: incubator-hawq
Updated Branches:
  refs/heads/master d72d0fa04 -> 87d13b673


HAWQ-452. Remove the workfile views from hawq_toolkit


Project: http://git-wip-us.apache.org/repos/asf/incubator-hawq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-hawq/commit/87d13b67
Tree: http://git-wip-us.apache.org/repos/asf/incubator-hawq/tree/87d13b67
Diff: http://git-wip-us.apache.org/repos/asf/incubator-hawq/diff/87d13b67

Branch: refs/heads/master
Commit: 87d13b673c19d0975cd2408c732c8c4836640e66
Parents: d72d0fa
Author: ivan <iweng@pivotal.io>
Authored: Thu Mar 10 09:16:04 2016 +0800
Committer: ivan <iweng@pivotal.io>
Committed: Thu Mar 10 09:16:04 2016 +0800

----------------------------------------------------------------------
 src/backend/catalog/gp_toolkit.sql.in | 223 -----------------------------
 1 file changed, 223 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-hawq/blob/87d13b67/src/backend/catalog/gp_toolkit.sql.in
----------------------------------------------------------------------
diff --git a/src/backend/catalog/gp_toolkit.sql.in b/src/backend/catalog/gp_toolkit.sql.in
index 9141d1e..a620284 100644
--- a/src/backend/catalog/gp_toolkit.sql.in
+++ b/src/backend/catalog/gp_toolkit.sql.in
@@ -1833,229 +1833,6 @@ GRANT SELECT ON TABLE %%JETPACK_PREFIX%%size_of_database TO public;
 
 --GRANT SELECT ON %%JETPACK_PREFIX%%resqueue_status TO public;
 
--- Workfile views
---------------------------------------------------------------------------------
-
---------------------------------------------------------------------------------
--- @function: 
---		%%JETPACK_PREFIX_AUX%%workfile_entries_f
---
--- @in:
---
--- @out:
---		int - segment id
---		text - path to workfile set, 
---		int - hash value of the spilling operator, 
---		bigint - size in bytes, 
---		int - utility, 
---		int - state, 
---		int - workmem in kilobytes,
---		int - type of the spilling operator, 
---		int - containing slice,
---		int - sessionid, 
---		int - command_cnt,
---		timestamptz - time of query start,
---		int - number of files
---
--- @doc:
---		UDF to retrieve workfile sets currently present on disk on one segment
---		
---------------------------------------------------------------------------------
-
-CREATE FUNCTION %%JETPACK_PREFIX_AUX%%workfile_entries_f()
-RETURNS SETOF record
-AS '%%WORKFILE_MODULE%%', 'gp_workfile_mgr_cache_entries'
-LANGUAGE C IMMUTABLE;
-
-GRANT EXECUTE ON FUNCTION %%JETPACK_PREFIX_AUX%%workfile_entries_f() TO public;
-
-
---------------------------------------------------------------------------------
--- @view: 
---		 %%JETPACK_PREFIX_AUX%%workfile_data
---
--- @doc:
---		Auxiliary view with workfile entries used to construct the full entries view
---		
---------------------------------------------------------------------------------
-
-CREATE VIEW  %%JETPACK_PREFIX_AUX%%workfile_data AS
-   SELECT C.*
-          FROM gp_dist_random('gp_version_at_initdb'), %%JETPACK_PREFIX_AUX%%workfile_entries_f()
AS C (
-            segid int, 
-            path text, 
-            hash int, 
-            size bigint, 
-            utility int, 
-            state int, 
-            workmem int,
-            optype text, 
-            slice int,
-            sessionid int, 
-            commandid int,
-            query_start timestamptz, 
-            numfiles int
-          )
-    UNION ALL
-    SELECT C.*
-          FROM gp_version_at_initdb, %%JETPACK_PREFIX_AUX%%workfile_entries_f() AS C (
-            segid int, 
-            path text, 
-            hash int, 
-            size bigint, 
-            utility int, 
-            state int, 
-            workmem int,
-            optype text, 
-            slice int,
-            sessionid int, 
-            commandid int,
-            query_start timestamptz, 
-            numfiles int
-          );
-
-GRANT SELECT ON %%JETPACK_PREFIX_AUX%%workfile_data TO public;
-
---------------------------------------------------------------------------------
--- @view: 
---		%%JETPACK_PREFIX%%workfile_entries
---
--- @doc:
---		List of all the workfile sets currently present on disk
---		
---------------------------------------------------------------------------------
-
-CREATE VIEW %%JETPACK_PREFIX%%workfile_entries AS
-SELECT S.datname, 
-       (CASE WHEN (C.state = 1) THEN S.procpid ELSE NULL END) AS procpid, 
-       C.sessionid as sess_id, 
-       C.commandid as command_cnt,
-       S.usename, 
-       (CASE WHEN (C.state = 1) THEN S.current_query ELSE NULL END) as current_query, 
-       C.segid, 
-       C.slice, 
-       C.optype, 
-       C.workmem, 
-       C.size, 
-       C.numfiles,
-       C.path as directory, 
-       (CASE WHEN (C.state = 1) THEN 'RUNNING' WHEN (C.state = 2) THEN 'CACHED' WHEN (C.state
= 3) THEN 'DELETING' ELSE 'UNKNOWN' END) as state, 
-       C.utility
-FROM  %%JETPACK_PREFIX_AUX%%workfile_data C LEFT OUTER JOIN 
-   pg_stat_activity as S
-ON C.sessionid = S.sess_id;
-
-GRANT SELECT ON %%JETPACK_PREFIX%%workfile_entries TO public;
-
---------------------------------------------------------------------------------
--- @view: 
---		%%JETPACK_PREFIX%%workfile_usage_per_segment
---
--- @doc:
---		Amount of disk space used for workfiles at each segment
---		
---------------------------------------------------------------------------------
-
--- CREATE VIEW %%JETPACK_PREFIX%%workfile_usage_per_segment AS
--- SELECT gpseg.content AS segid, COALESCE(SUM(wfe.size),0) AS size, 
--- 	SUM(wfe.numfiles) AS numfiles
--- FROM (
--- 	SELECT content 
--- 	FROM gp_segment_configuration 
--- 	WHERE role = 'p') gpseg 
--- LEFT JOIN %%JETPACK_PREFIX%%workfile_entries wfe 
--- ON (gpseg.content = wfe.segid) 
--- GROUP BY gpseg.content;
-
--- GRANT SELECT ON %%JETPACK_PREFIX%%workfile_usage_per_segment TO public;
-
---------------------------------------------------------------------------------
--- @view: 
---		%%JETPACK_PREFIX%%workfile_usage_per_query
---
--- @doc:
---		Amount of disk space used for workfiles by each query
---		
---------------------------------------------------------------------------------
-
-CREATE VIEW %%JETPACK_PREFIX%%workfile_usage_per_query AS
-SELECT datname, procpid, sess_id, command_cnt, usename, current_query, segid, state, 
-	SUM(size) AS size, SUM(numfiles) AS numfiles 
-FROM %%JETPACK_PREFIX%%workfile_entries
-GROUP BY (datname, procpid, sess_id, command_cnt, usename, current_query, segid, state);
-
-GRANT SELECT ON %%JETPACK_PREFIX%%workfile_usage_per_query TO public;
-
---------------------------------------------------------------------------------
--- @function: 
---		%%JETPACK_PREFIX_AUX%%workfile_cache_clear_f(content int)
---
--- @in:
---		int - segment id
--- @out:
---		int - number of workfile sets deleted
---
--- @doc:
---		UDF to clear the workfile cache on one segment
---		
---------------------------------------------------------------------------------
-
-CREATE FUNCTION %%JETPACK_PREFIX_AUX%%workfile_cache_clear_f(content int)
-    RETURNS SETOF int
-AS '%%WORKFILE_MODULE%%', 'gp_workfile_mgr_clear_cache' LANGUAGE C IMMUTABLE;
-
-REVOKE ALL ON FUNCTION %%JETPACK_PREFIX_AUX%%workfile_cache_clear_f(int) FROM public;
-
---------------------------------------------------------------------------------
--- @function: 
---		%%JETPACK_PREFIX%%workfile_cache_clear_segment(content int)
---
--- @in:
---		int - segment id
--- @out:
---		int - number of workfile sets deleted
---
--- @doc:
---		Clear the workfile cache on one segment
---		
---------------------------------------------------------------------------------
-
-CREATE FUNCTION %%JETPACK_PREFIX%%workfile_cache_clear_segment(content int)
-RETURNS SETOF int
-AS
-$$
- SELECT C.* FROM gp_dist_random('gp_version_at_initdb'), %%JETPACK_PREFIX_AUX%%workfile_cache_clear_f($1)
as C
- UNION ALL
- SELECT C.* FROM gp_version_at_initdb, %%JETPACK_PREFIX_AUX%%workfile_cache_clear_f($1) as
C;
-$$
-LANGUAGE SQL;
-
-REVOKE ALL ON FUNCTION %%JETPACK_PREFIX%%workfile_cache_clear_segment(int) FROM public;
-
---------------------------------------------------------------------------------
--- @function: 
---		%%JETPACK_PREFIX%%workfile_cache_clear()
---
--- @in:
---
--- @out:
---		int - number of workfile sets deleted
---
--- @doc:
---		Clear the workfile caches on all segments
---		
---------------------------------------------------------------------------------
-
-CREATE FUNCTION %%JETPACK_PREFIX%%workfile_cache_clear()
-RETURNS SETOF int
-AS
-$$
-  SELECT * from %%JETPACK_PREFIX%%workfile_cache_clear_segment(-2)
-$$
-LANGUAGE SQL; 
-
-REVOKE ALL ON FUNCTION %%JETPACK_PREFIX%%workfile_cache_clear() FROM public;
-
 --------------------------------------------------------------------------------
 -- @function:
 --		%%JETPACK_PREFIX%%dump_query_oids(text)


Mime
View raw message