Classes
InMemorySinkStage(c)
InMemorySinkStage
Collects incoming messages into a list that can be accessed after the pipeline is complete.