Thanks Gordon for your explanation.
Mans
On Wednesday, December 20, 2017 2:16 PM, Tzu-Li (Gordon) Tai
wrote:
#yiv6533607487 body{font-family:Helvetica, Arial;font-size:13px;}Hi Mans,
What's the difference between an operator and a function ?
An operator in Flink needs to handle pr
Hi Mans,
What's the difference between an operator and a function ?
An operator in Flink needs to handle processing of watermarks, records, and
checkpointing of the operator state.
To implement one, you need to extend the AbstractStreamOperator base class.
It is considered a very low-level API
