Piyush Katariya corporatepiyush

Veggie, Software Architect, Truth Seeker

corporatepiyush / dial-pq-via-ssh.go

Created May 27, 2023 09:02 — forked from vinzenz/dial-pq-via-ssh.go

Use postgres via SSH in Golang

corporatepiyush / rollups.sql

Created November 14, 2019 18:27 — forked from marcocitus/rollups.sql

Efficient real-time rollups with backfilling in Citus

	CREATE TABLE rollups (
	name text,
	rolled_up_generation bigint default -1
	);

	-- Create a stub on workers to allow usage as a default in distributed tables
	SELECT run_command_on_workers($$
	CREATE OR REPLACE FUNCTION current_rollup_generation(rollup_name text)
	RETURNS bigint LANGUAGE sql
	AS $function$

corporatepiyush / example.sql

Created November 7, 2019 13:19 — forked from marcocitus/example.sql

Safe incremental rollups on Postgres and Citus

	-- Create the raw events table
	CREATE TABLE page_views (
	site_id int,
	path text,
	client_ip inet,
	view_time timestamptz default now(),
	view_id bigserial
	);

	-- Allow fast lookups of ranges of sequence IDs

corporatepiyush / pubsub-coordinator.sql

Created September 13, 2018 10:33 — forked from marcocitus/pubsub-coordinator.sql

Prototype for PubSub on PG 10 with Citus 7

	/* commands to run on the coordinator */

	CREATE EXTENSION citus;
	SELECT master_add_node('10.0.0.2', 5432);
	SELECT master_add_node('10.0.0.3', 5432);
	SELECT start_metadata_sync_to_node(nodename, nodeport) FROM pg_dist_node;
	SET citus.replication_model TO 'streaming'

	CREATE TABLE events (
	event_id bigserial primary key,