Add purge bucket ability to IPersist streams with sql implementation