Flink实战(八) - Streaming Connectors 编程

javaedge 2019-07-26

云栖社区 服务器 Apache 配置 ask Consumer 编程 source 存储 数据存储

1 概览

1.1 预定义的源和接收器

Flink内置了一些基本数据源和接收器,并且始终可用。该预定义的数据源包括文件,目录和插socket,并从集合和迭代器摄取数据。该预定义的数据接收器支持写入文件和标准输入输出及socket。

1.2 绑定连接器

连接器提供用于与各种第三方系统连接的代码。目前支持这些系统:

  • 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 PubSu
登录 后评论
下一篇
冒顿单于
7698人浏览
2019-08-28
相关推荐
Flink Window 排序
1301人浏览
2019-03-02 21:58:38
Apache Flink实战(一) - 简介
923人浏览
2019-04-26 20:04:27
Apache Flink实战(一) - 初识Flink
1569人浏览
2019-06-15 03:00:21
大数据开发必备技能
1512人浏览
2019-04-19 15:50:14
Apache Beam初探
642人浏览
2017-01-17 10:10:30
0
0
0
634