NBI大数据

LV2
举报
发表了文章

(4)SparkSQL中如何定义UDF和使用UDF

Spark SQL中用户自定义函数,用法和Spark SQL中的内置函数类似;是saprk SQL中内置函数无法满足要求,用户根据业务需求自定义的函数。

NBI大数据
SQLspark
发表了文章

(3)sparkstreaming从kafka接入实时数据流最终实现数据可视化展示

(1)sparkstreaming从kafka接入实时数据流最终实现数据可视化展示,我们先看下整体方案架构:

NBI大数据
大数据处理套件大数据可视交互系统大数据解决方案大数据
发表了文章

(2)sparkstreaming滚动窗口和滑动窗口演示

一、滚动窗口(Tumbling Windows) 滚动窗口有固定的大小,是一种对数据进行均匀切片的划分方式。窗口之间没有重叠,也不会有间隔,是“首尾相接”的状态...

NBI大数据
spark大数据处理套件大数据大数据解决方案大数据可视交互系统
发表了文章

(1)sparkstreaming结合sparksql读取socket实时数据流

Spark Streaming是构建在Spark Core的RDD基础之上的,与此同时Spark Streaming引入了一个新的概念:DStream(Disc...

NBI大数据
sparkHadoop大数据处理套件大数据
发表了文章

(6)Flink CEP SQL模拟账号短时间内异地登录风控预警

(1)通过将xxx平台用户登录时的登录日志发送到kafka(本文代码演示用的socket);

NBI大数据
HadoopFlink营销风控金融风控风控平台
发表了文章

(5)Flink CEP SQL四种匹配模式效果演示

从匹配成功的事件序列中最后一个对应于patternItem的事件开始进行下一次匹配

NBI大数据
FlinkHadoop实时风控大数据大数据解决方案
发表了文章

(4)Flink CEP SQL贪婪词量演示

基于上一篇(3)Flink CEP SQL宽松近邻代码演示的延展,在上一篇中我们使用贪婪词量 +(至少匹配1行或多行),本篇将演示多种贪婪词量的效果:

NBI大数据
大数据处理套件大数据Flink营销风控金融风控
发表了文章

(2)Flink CEP SQL严格近邻代码演示-风控系统构建利器

上一篇我们对Flink CEP做了简单介绍,这一篇我们通过代码来演示一下Flink CEP SQL中的严格近邻效果:

NBI大数据
大数据Flink实时风控营销风控金融风控
发表了文章

(1)Flink CEP复杂事件处理引擎介绍

复杂事件处理(CEP)既是把不同的数据看做不同的事件,并且通过分析事件之间的关系建立起一套事件关系序列库。利用过滤,聚合,关联性,依赖,层次等技术,最终实现由简...

NBI大数据
Flink大数据处理套件大数据解决方案大数据大数据可视交互系统
发表了文章

(8)FlinkSQL自定义UDF

Flink提供了自定义函数的基础能力,在需要满足特殊业务场景需求时,根据自身需要按需定制自己的UDF 下面将简单演示一个UDF的定义和UDF的使用过程:

NBI大数据
Flink大数据处理套件大数据解决方案大数据
发表了文章

(7)FlinkSQL将kafka数据写入到mysql方式二

NBI大数据
Flink大数据处理套件大数据解决方案大数据
发表了文章

(6)FlinkSQL将kafka数据写入到mysql方式一

NBI大数据
Flink大数据处理套件大数据解决方案大数据
发表了文章

(5)FlinkSQL将socket数据写入到mysql方式二

NBI大数据
Flink大数据处理套件大数据解决方案大数据
发表了文章

(4)FlinkSQL将socket数据写入到mysql方式一

本章节主要演示从socket接收数据,通过滚动窗口每30秒运算一次窗口数据,然后将结果写入Mysql数据库

NBI大数据
Flink大数据处理套件大数据大数据解决方案
发表了文章

(3)FlinkSQL滑动窗口demo演示

滑动窗口(Sliding Windows)与滚动窗口类似,滑动窗口的大小也是固定的。区别在于,窗口之间并不是首尾相接的,而是可以“错开”一定的位置。如果看作一个...

NBI大数据
Flink大数据
发表了文章

(2)FlinkSQL滚动窗口demo演示

滚动窗口(Tumbling Windows) 滚动窗口有固定的大小,是一种对数据进行均匀切片的划分方式。窗口之间没有重叠,也不会有间隔,是“首尾相接”的状态。滚...

NBI大数据
Flink
发表了文章

(1)通过FlinkSQL将数据写入mysql demo

FlinkSQL的出现,极大程度上降低了Flink的编程门槛,更加容易理解和掌握使用。今天将自己的笔记分享出来,希望能帮助在这方面有需要的朋友。

NBI大数据
Flink
发表了文章

NBI可视化平台快速入门教程(五)编辑器功能操作介绍

(4)预览时自适应 浏览页面时,系统会自动计算页面大小和组件大小,达到自适应效果(注意:等比例自适应效果最佳,比如页面大小设置的是16:9的大小,然在不同16:...

NBI大数据
大数据处理套件大数据可视交互系统大数据解决方案
发表了文章

NBI可视化平台快速入门教程(四)数据可视化编辑器介绍

(2.1)项目列表,项目列表是用于存放可视化页面,创建后的可视化页面将会出现在这里

NBI大数据
大数据处理套件大数据可视交互系统大数据解决方案大数据数据可视化
发表了文章

NBI可视化平台快速入门教程(三)带参工作表创建

NBI大数据
大数据处理套件大数据可视交互系统大数据解决方案大数据

个人简介

个人成就

扫码关注腾讯云开发者

领取腾讯云代金券