本文通过以下方面,为您介绍Flink DataStream 的使用方法。
DataFlow集群的Flink DataStream API完全兼容开源的Flink版本,关于Flink DataStream API的详细信息,请参见Flink DataStream API Programming Guide。
上下游存储(Connector)
- 开源Flink的上下游存储,请参见DataStream Connectors。
- DataFlow集群中新增支持的上下游存储,请参见下表。
Connector版本 EMR版本 Connector类型 文档及Demo 1.13-vvr-4.0.10及以上 EMR-3.38.0及以上 ververica-connector-datahub ververica-connector-kafka - ververica-connector-odps
- ververica-connector-continuous-odps
ververica-connector-mysql-cdc 文档:MySQL CDC DataStream Connector