The CollectionsEnvironment is a different execution backend for the Batch
API - based entirely on Java Collections. The use case for this backend is
to embed Flink programs into other programs in an extremely lightweight
fashion, without threading overheads, serialization, anything.
The tests are
Hey all,
Currently streaming topology tests use TestStreamEnvironment and static
collections as sinks for assertion. I see that that the batch API tests use
CollectionEnvironment for this purpose.
Is there any reason streaming do not have something like that?
I think it would be more compact and
