added methods to bulk insert per windowId and retreive last windowId from the data store
added windowId tracking in aggregations operator to make sure replayed tulples are not processed again