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
登录 后评论
下一篇
阿里巴巴云原生小助手
4269人浏览
2020-02-11
相关推荐
Apache Beam初探
823人浏览
2017-01-17 10:10:30
Flink Batch SQL 1.10 实践
1997人浏览
2019-12-12 11:32:49
Apache Flink实战(一) - 简介
1519人浏览
2019-04-26 20:04:27
Apache Flink实战(一) - 初识Flink
2268人浏览
2019-06-15 03:00:21
Flink Window 排序
2272人浏览
2019-03-02 21:58:38
0
0
0
1280