{"action":"created","issue":{"url":"https://api.github.com/repos/pipelinedb/pipelinedb/issues/1199","labels_url":"https://api.github.com/repos/pipelinedb/pipelinedb/issues/1199/labels{/name}","comments_url":"https://api.github.com/repos/pipelinedb/pipelinedb/issues/1199/comments","events_url":"https://api.github.com/repos/pipelinedb/pipelinedb/issues/1199/events","html_url":"https://github.com/pipelinedb/pipelinedb/pull/1199","id":109156308,"number":1199,"title":"1078 adhoc backend","user":{"login":"loadzero","id":10953013,"avatar_url":"https://avatars.githubusercontent.com/u/10953013?v=3","gravatar_id":"","url":"https://api.github.com/users/loadzero","html_url":"https://github.com/loadzero","followers_url":"https://api.github.com/users/loadzero/followers","following_url":"https://api.github.com/users/loadzero/following{/other_user}","gists_url":"https://api.github.com/users/loadzero/gists{/gist_id}","starred_url":"https://api.github.com/users/loadzero/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/loadzero/subscriptions","organizations_url":"https://api.github.com/users/loadzero/orgs","repos_url":"https://api.github.com/users/loadzero/repos","events_url":"https://api.github.com/users/loadzero/events{/privacy}","received_events_url":"https://api.github.com/users/loadzero/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":5,"created_at":"2015-09-30T18:54:46Z","updated_at":"2015-10-05T17:29:18Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/pipelinedb/pipelinedb/pulls/1199","html_url":"https://github.com/pipelinedb/pipelinedb/pull/1199","diff_url":"https://github.com/pipelinedb/pipelinedb/pull/1199.diff","patch_url":"https://github.com/pipelinedb/pipelinedb/pull/1199.patch"},"body":"Adhoc query support (sliding windows not implemented yet)\r\n\r\nTo try it out, run \r\n```\r\npadhoc 'select key::text, count(*) from stream group by key'\r\n```\r\n\r\nand then insert some rows\r\n\r\n```\r\nbin/generate-inserts --stream stream  --key=str --value=int --batchsize=100 --n=1000  | psql\r\n```\r\n\r\nYou should see the query result live updating in the padhoc client.\r\n\r\nIf you execute from inside psql, you can see the adhoc messages streaming in copy format\r\n\r\n```\r\npsql -c 'select key::text, count(*) from stream group by key'\r\n```\r\n\r\nIssues.\r\n\r\nSliding windows not supported.\r\n\r\nIPC for adhoc queries needs looking at, I have currently piggy backed on the mechanism for bg workers, but it is a bit of a hack. see cont_scheduler.c:start_group and \r\ncont_adhoc.c:get_cont_query_proc\r\n\r\nPerhaps adhoc queries should get their own tuple buffer?"},"comment":{"url":"https://api.github.com/repos/pipelinedb/pipelinedb/issues/comments/145605842","html_url":"https://github.com/pipelinedb/pipelinedb/pull/1199#issuecomment-145605842","issue_url":"https://api.github.com/repos/pipelinedb/pipelinedb/issues/1199","id":145605842,"user":{"login":"derekjn","id":384666,"avatar_url":"https://avatars.githubusercontent.com/u/384666?v=3","gravatar_id":"","url":"https://api.github.com/users/derekjn","html_url":"https://github.com/derekjn","followers_url":"https://api.github.com/users/derekjn/followers","following_url":"https://api.github.com/users/derekjn/following{/other_user}","gists_url":"https://api.github.com/users/derekjn/gists{/gist_id}","starred_url":"https://api.github.com/users/derekjn/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/derekjn/subscriptions","organizations_url":"https://api.github.com/users/derekjn/orgs","repos_url":"https://api.github.com/users/derekjn/repos","events_url":"https://api.github.com/users/derekjn/events{/privacy}","received_events_url":"https://api.github.com/users/derekjn/received_events","type":"User","site_admin":false},"created_at":"2015-10-05T17:29:18Z","updated_at":"2015-10-05T17:29:18Z","body":"To summarize the outstanding issues so we can just cross them off here:\r\n\r\n* Enter adhoc loop via a function call\r\n* TupleBuffer reading rework\r\n* `padhoc` error propagation\r\n* `padhoc` connection options\r\n* `GetContinuousViewOverlayPlan`\r\n* `nice`"}}