Flink Datastream作业开发参考示例

Flink Datastream作业开发可以参考以下示例：

• DataHub DataStream Connector示例：如果通过DataStream的方式读写DataHub数据，则需要使用DataHub DataStream Connector连接Flink全托管。

• MaxCompute DataStream Connector示例：如果通过DataStream的方式读写MaxCompute数据，则需要使用MaxCompute DataStream Connector连接Flink全托管。

• Kafka DataStream Connector示例：如果通过DataStream的方式以精确一次（Exactly-once）的语义在Kafka Topic中读写数据，则需要使用Kafka DataStream Connector连接Flink全托管。

• MySQL CDC DataStream Connector示例：MySQL CDC DataStream Connector支持从全量读取到增量读取的无缝切换，保证数据不重不丢。

• Hologres DataStream Connector示例：如果通过DataStream的方式读写Hologres数据，则需要使用Hologres DataStream Connector连接Flink全托管。

• RocketMQ DataStream Connector示例：如果通过DataStream的方式读写RocketMQ数据，则需要使用RocketMQ DataStream Connector连接Flink全托管。

• 动态CEP中规则的JSON格式定义示例：介绍了CEP中规则的JSON格式相关信息。