logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

【Flink】Window API

Window APIWindow的概念窗口窗口的分类Window API窗口分配器(window assigner)窗口函数(window function)其它可选 APIWindow的概念窗口一般真实的流都是无界的,怎样处理无界的数据?可以把无限的数据流进行切分,得到有限的数据集进行处理 —— 也就是得到有界流窗口(window)就是将无限流切割为有限流的一种方式,它会将流数据分发到有限大小的

#flink#大数据#big data
【Flink Scala】window API

window APIwindow APIWindow 概述window窗口的分类Window的使用测试window APIWindow 概述streaming流式计算是一种被设计用于处理无限数据集的数据处理引擎,而无限 数据集是指一种不断增长的本质上无限的数据集,而window 是一种切割无限数据 为有限块进行处理的手段。 Window是无限数据流处理的核心,Window将一个无限的 stream

文章图片
#scala
【Flink Scala】Table API 自定义函数

自定义函数内置函数UDF注册用户自定义函数 UDF标量函数表函数聚合函数表聚合函数Flink Table和 SQL内置了很多 SQL 中支持的函数;如果有无法满足的需要,则可以实 现用户自定义的函数(UDF)来解决。内置函数Flink Table API 和 SQL为用户提供了一组用于数据转换的内置函数。SQL中支持的很多 函数,Table API和SQL都已经做了实现,其它还在快速开发扩展中。以

文章图片
#scala
【Flask + Eacharts】使用Flask + ECharts对考研数据进行可视化

其他的可视化试题,药品数据的可视化对考研数据进行可视化数据的分析和查看数据的查看数据的分析对考研数据进行数据可视化招生专业数量前十条形图数据的分析和查看数据的查看我们可以先查看数据库中的数据我们使用Python读取数据import pandas as pdfrom sqlalchemy import create_engineimport pymysql# 自定义函数连接数据库获取数据def co

文章图片
#echarts
nested exception is org.thymeleaf.exceptions.TemplateInputException: An error happened during templa

报错代码2021-07-09 17:24:56.671 ERROR 14340 --- [nio-8080-exec-5] o.a.c.c.C.[.[.[/].[dispatcherServlet]: Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request

#html#html5#css3 +1
【Error】Error while executing topic command : Replication factor: 1 larger than available brokers: 0

今天在使用Kafka创建topic时,出现了以下一个错误【Error】Error while executing topic command : Replication factor: 1 larger than available brokers: 0提示我broker少于副本数,可是明明有三个broker并且只设置了2个replication我们可以使用下列命令去zookeeper中查看启动了

#kafka#big data#zookeeper
request.getSession().getAttribute 获取不到值,获取到的是null

request.getSession().getAttribute 获取不到值,获取到的是null命名已经设置了session值,却一直找不到,为空request.getSession().setAttribute("VerifyCode", code);经过仔细的查找发现是跨域问题有时候用的是本地localhost有时用的是127.0.0.1方法一:全改成一样的域名方法二:在要查找时加上resp

#java#http
【Flink Kafka】Flink程序连接Kafka没输出也不报错

Flink程序连接Kafka没输出也不报错本人最近在使用Kafka作为数据源输出数据到Flink时遇到一个问题,那就是既没有结果输出,也没有报错代码如下package Sourceimport org.apache.flink.api.common.serialization.SimpleStringSchemaimport org.apache.flink.streaming.api.scala

文章图片
#kafka#scala
Hadoop集群的完整搭建(Hadoop完全分布式+ZooKeeper+Mysql+Hive+Hbase完全分布式+Spark完全分布式)

Hadoop集群的完整搭建准备工作网络环境的配置修改网关、IP配置映射、主机名重启网络服务,测试ssh的配置jdk的安装Hadoop完全分布式的安装准备工作修改配置文件slaveshadoop-env.shyarn-env.shcore-site.xmlhdfs-site.xmlmapred-site.xmlyarn-site.xml分发到其他节点测试安装Zookeeper准备工作修改配置文件分发

#大数据#hadoop#hive +2
【Error】 WARN [Producer clientId=console-producer] Error while fetching metadata wit

今天在使用Kafka生产数据时出现一个错误,具体报错如下2021-12-29 18:17:50,662] WARN [Producer clientId=console-producer] Error while fetching metadata with correlation id 3 : {first=LEADER_NOT_AVAILABLE} (org.apache.kafka.clie

#kafka#zookeeper#big data
暂无文章信息