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