Describe how you would implement a memory-efficient data structure for streaming computation in Eventual pipelines.