【代码】spark: 从pulsar中读取数据。

二、注入RestHighLevelClient,并调用相关API。一、配置RestHighLevelClient。

【代码】spark stream:从Kafka中读取数据。

【代码】spark streaming:通过Redis来控制任务的关闭。

二、添加mybatis starter和hive依赖。五、定义controller,注入mapper并使用。启动hiveserver2。四、定义mapper。

【代码】Spring Mvc:使用ModelAndView返回json。

实体类没加setter&getter

其中ES服务器的地址复用spring data ES 的spring.elasticsearch.uris。一、依赖：（要根据不同版本的ES来调整依赖,否则会报错，不支持太低版本的ES，比如7.6以下的）四、使用ElasticsearchClient操作索引。三、配置ElasticsearchClient。

boot

二、可以进行全局配置（单独使用MyBatis时可如下配置）如果不进行配置，将报错。