Are there any resources/documentation out there on how to build an operator? Or, anything that explains how to work with the Flink internals (particularly the DataStream API)?

Awesome - Thank you!