#pragma D option quiet

BEGIN { self->ts = 0; }

postgresql*:::statement-start
/self->ts/
{
  @a["aggregate"] = lquantize((timestamp - self->ts)/1000, 0, 15000, 1000);
  self->ts = timestamp;
}

postgresql*:::statement-start
{
  self->sql = copyinstr(arg0);
  self->ts = (self->sql == "<IDLE>") ? 0 : timestamp;
}

tick-1sec
{
  printf("");
  printa(@a);
  clear(@a);
}