Streaming - Active agent for rolling a streaming partition into a standard partition

The task is to implement an entity which rolls all the committed transactions from the streaming partition into a new standard partition atomically.