锐单电子商城 , 一站式电子元器件采购平台!
  • 电话:400-990-0325

Flink实时计算运用(六)Flink 连接器的使用

时间:2022-10-25 21:30:00 管连接用连接器13p连接器1连接器dr146连接器连接器20203r004连接器

1. Flink Connectors 介绍

Flink 连接器包含数据源输入与汇聚输出两部分。Flink数据源输入包括文件、目录、Socket以及 支持从collections 和 iterators 中读取数据;汇聚输出支持把数据写入文件、标准输出(stdout)、输出标准错误(stderr)和 socket。

官方地址

Flink还可支持扩展连接器,可与第三方系统交互。目前支持以下系统:

  • Apache Kafka (source/sink)
  • Apache Cassandra (sink)
  • Amazon Kinesis Streams (source/sink)
  • Elasticsearch (sink)
  • Hadoop FileSystem (sink)
  • RabbitMQ (source/sink)
  • Apache NiFi (source/sink)
  • Twitter Streaming API (source)
  • Google PubSub (source/sink)
  • JDBC (sink)****

常用的是Kafka、ES、HDFS以及JDBC。

2. JDBC 读写连接模式的读写

3. HDFS 连接方式的读取与写入

相关文章