This would allow us to create a cpu-intensive stream processor without having to set up a kafka/change stream source for it. I am not sure how we want to expose it in the syntax. If we don't want to expose it to the user, could we come up with some way to specify such internal fields for test-only purposes?