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

其实如果我是面试官的话，我如果感觉你都把刚才那些问题都答出来了，我可能会继续刨根问底，深挖，问你，直到把你给问倒

开源的消息代理和队列服务器，通过普通协议在完全不同的应用间共享数据，使用Erlang语言编写，并且基于AMQP协议。

应该得保证消息按照顺序执行的吧! 不然本来是：增加->修改->删除 你楞是换了顺序给执行成:删除->修改->增加 全错!!!

MQ的高可用性怎么保证？这样就是你用过哪个MQ，你就说说你对那个MQ的高可用性的理解。

地域: ip转换 Spark SQL项目实战 客户端:useragent获取 Hadoop基础教程

rabbitmq、rocketmq、kafka都可能出现重复消费，因为这个问题不是MQ自身保证的，是开发人员保证的。

Java消息服务（Java Message Service，JMS）应用程序接口是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。 Java消息服务是一个与具体平台无关的API，绝大多数MOM提供...

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-6wtQxLP6-1626354186973)(/img/image-20210506154426999.png)]

一些简单的聚合函数： count 、longSum、longMin、longMax、doubleSum、doubleMin、doubleMax