Repository: incubator-madlib
Updated Branches:
  refs/heads/master 4e8616b7a -> 019247108


BFS: Drop temporary tables on completion.

Some temp tables (summary and toupdate) used for storing intermediate
results were not dropped, dropping them now.


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

Branch: refs/heads/master
Commit: 019247108df4acc848bba0faf87f2ca34ea1d24c
Parents: 4e8616b
Author: Nandish Jayaram <njaya...@apache.org>
Authored: Thu Aug 10 11:28:27 2017 -0700
Committer: Nandish Jayaram <njaya...@apache.org>
Committed: Thu Aug 10 11:28:27 2017 -0700

----------------------------------------------------------------------
 src/ports/postgres/modules/graph/bfs.py_in | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-madlib/blob/01924710/src/ports/postgres/modules/graph/bfs.py_in
----------------------------------------------------------------------
diff --git a/src/ports/postgres/modules/graph/bfs.py_in 
b/src/ports/postgres/modules/graph/bfs.py_in
index c9aa981..b3537d3 100644
--- a/src/ports/postgres/modules/graph/bfs.py_in
+++ b/src/ports/postgres/modules/graph/bfs.py_in
@@ -374,6 +374,8 @@ def graph_bfs(schema_madlib, vertex_table, vertex_id, 
edge_table,
             # stored in this iteration. This is used to check if the iterations
             # need to continue.
             vct = plpy.execute(count_qry.format(**locals()))[0]['count']
+        # Drop temp tables
+        plpy.execute("DROP TABLE IF EXISTS {0},{1}".format(toupdate, message))
 
     return None
 

Reply via email to