暂无搜索历史
Spark SQL中用户自定义函数，用法和Spark SQL中的内置函数类似；是saprk SQL中内置函数无法满足要求，用户根据业务需求自定义的函数。
（1）sparkstreaming从kafka接入实时数据流最终实现数据可视化展示，我们先看下整体方案架构：
一、滚动窗口（Tumbling Windows） 滚动窗口有固定的大小，是一种对数据进行均匀切片的划分方式。窗口之间没有重叠，也不会有间隔，是“首尾相接”的状态...
Spark Streaming是构建在Spark Core的RDD基础之上的，与此同时Spark Streaming引入了一个新的概念：DStream（Disc...
（1）通过将xxx平台用户登录时的登录日志发送到kafka（本文代码演示用的socket）；
从匹配成功的事件序列中最后一个对应于patternItem的事件开始进行下一次匹配
基于上一篇（3）Flink CEP SQL宽松近邻代码演示的延展，在上一篇中我们使用贪婪词量 +（至少匹配1行或多行），本篇将演示多种贪婪词量的效果：
上一篇我们对Flink CEP做了简单介绍，这一篇我们通过代码来演示一下Flink CEP SQL中的严格近邻效果：
复杂事件处理(CEP)既是把不同的数据看做不同的事件，并且通过分析事件之间的关系建立起一套事件关系序列库。利用过滤，聚合，关联性，依赖，层次等技术，最终实现由简...
Flink提供了自定义函数的基础能力，在需要满足特殊业务场景需求时，根据自身需要按需定制自己的UDF 下面将简单演示一个UDF的定义和UDF的使用过程：
public static void main(String[] args) throws Exception { StreamExecuti...
图片这里不展开zookeeper、kafka安装配置（1）首先需要启动zookeeper和kafka图片（2）定义一个kafka生产者package com.p...
本章节主要演示从socket接收数据，通过滚动窗口每30秒运算一次窗口数据，然后将结果写入Mysql数据库
滑动窗口（Sliding Windows）与滚动窗口类似，滑动窗口的大小也是固定的。区别在于，窗口之间并不是首尾相接的，而是可以“错开”一定的位置。如果看作一个...
滚动窗口（Tumbling Windows） 滚动窗口有固定的大小，是一种对数据进行均匀切片的划分方式。窗口之间没有重叠，也不会有间隔，是“首尾相接”的状态。滚...
FlinkSQL的出现，极大程度上降低了Flink的编程门槛，更加容易理解和掌握使用。今天将自己的笔记分享出来，希望能帮助在这方面有需要的朋友。
（4）预览时自适应 浏览页面时，系统会自动计算页面大小和组件大小，达到自适应效果（注意：等比例自适应效果最佳，比如页面大小设置的是16:9的大小，然在不同16:...
（2.1）项目列表，项目列表是用于存放可视化页面，创建后的可视化页面将会出现在这里
NBI可视化平台快速入门教程（三）带参工作表创建1.如何创建带参工作表参数格式 $参数名称$，比如图片2.测试验证带参工作表是否正确图片3.输入测试参数图片4....
