flink wordcount demo job
PHP代码练习Demo02
<!DOCTYPE html> <html> <body> <?php echo "<h2>PHP is fun!</h2>"; echo "hello world"; echo "I'm about to learn PHP! <br>"; echo "This", " string", " wa ......
PHP代码练习Demo01
<!DOCTYPE html> <html> <body> <?php /* $x=5; function mytest(){ $y=10; echo "<p>测试函数内部的变量 </p>"; echo "变量 x 是： $x"; echo "<br>"; echo "变量 y 是 ：$y"; } ......
Elastic-job
## 1.介绍 elastic-job 是由当当网基于quartz 二次开发之后的分布式调度解决方案 ， 由两个相对独立的子项目Elastic-Job-Lite和Elastic-Job-Cloud组成 。 elastic-job主要的设计理念是无中心化的分布式定时调度框架，思路来源于Quartz的基 ......
html5页面中使用vue组件DEMO
资源下载 npm http-vue-loader：https://www.npmjs.com/package/http-vue-loader http-vue-loader.js下载 普通html5使用vue组件 1、页面引入相关JS文件 2、创建 components组件 3、主页面创建vue实例 ......
springboot xxl-job 执行器
maven依赖: <dependency> <groupId>com.xuxueli</groupId> <artifactId>xxl-job-core</artifactId> <version>2.4.0</version> </dependency> 配置文件: xxl: job: acce ......
【xiaoxiao-demo】SpringBoot 案例分享
> 预览图  里面列举了很多小的例子，欢迎大家借鉴。 ![](https://img2023.cnblogs.com ......
[LeetCode] 2323. Find Minimum Time to Finish All Jobs II
You are given two 0-indexed integer arrays jobs and workers of equal length, where jobs[i] is the amount of time needed to complete the ith job, and w ......
Linux系统Apache添加监听端口后无法启动服务并报错：Job for httpd.service failed because the control process exited with error code. See "systemctl status httpd.service" and "journalctl -xeu httpd.service" for details.
导言：这是SE Linux安全机制导致的。 解决方法： 1.查看当前httpd端口 # semanage port -l|grep http 2.将对应端口加入SE Linux，以8068为例 # semanage port -a -t http_port_t -p tcp 8068 3.再次查看 ......
麒麟系统开发笔记（十二）：在国产麒麟系统上编译GDAL库、搭建基础开发环境和基础Demo
前言 麒麟系统上做全球北斗定位终端开发，北斗GPS发过来的是大地坐标，应用需要的是经纬度坐标，所以需要转换，可以使用公式转换，但是之前涉及到了山He智能一个项目使用WG。 大地坐标简介 概述 大地坐标（Geodetic coordinate）是大地测量中以参考椭球面为基准面的坐标，地面点P的位置用大 ......
关于sam即segment-anythin中demo实现步骤
说实话，这个项目的readme写的真的不咋地，很乱。 我说说这个demo的部署实现步骤吧。 1.安装yarn，这个自己去安装吧 2.将demo/assets/data/dogs.jpg使用numpy读取，保存为npy文件，放在跟dogs.jpg同一目录下 image = cv2.imread('sr ......
flink个人理解
1.广播 想把配置streamConfig,广播到流stream中 stream.connect(streamConfig.broadcast(映射描述器msd)); // msd的作用有2(a.泛型, b.获取广播数据context.getBroadcastState(msd)只有通过这个msd才 ......
第三章 Flink 集群搭建
# Flink集群搭建 ```text Flink 可以选择的部署方式有： Local、Standalone（资源利用率低）、Yarn、Mesos、Docker、Kubernetes、AWS。 我们主要对 Standalone 模式和 Yarn 模式下的 Flink 集群部署进行分析。 我们对sta ......
Flink实时数仓
### 为什么分层？ 复杂的问题简单化 避免重复计算 参考大厂做法 ### ods层 1. 采集到ods链路： 用户行为数据（前端埋点）：前端埋点=》Nginx=》日志服务器（springboot--落盘成log）=》flume==》kafka：topic_log 业务数据（MySQL）：mysql ......
Flink 运行架构
# 第四章 Flink 运行架构 ## 4.1 Yarn 模式任务提交流程  ``` text (1)Fl ......
some proxy demo
let rawindexof = String.prototype.indexOf String.prototype.indexOf = function (str) { var res = rawindexof.call(this, str) console.log(`[String] "${th ......
Scrapy自带的断点续爬JOB-DIR参数
参考官方文档：[https://docs.scrapy.org/en/latest/topics/jobs.html?highlight=JOBDIR#jobs-pausing-and-resuming-crawls](https://docs.scrapy.org/en/latest/topics ......
全网最详细4W字Flink入门笔记（上）
本文已收录至Github，推荐阅读 👉 [Java随想录](https://github.com/ZhengShuHai/JavaRecord) 微信公众号：[Java随想录](https://mmbiz.qpic.cn/mmbiz_jpg/jC8rtGdWScMuzzTENRgicfnr91C5 ......
全网最详细4W字Flink入门笔记（下）
本文已收录至Github，推荐阅读 👉 [Java随想录](https://github.com/ZhengShuHai/JavaRecord) 微信公众号：[Java随想录](https://mmbiz.qpic.cn/mmbiz_jpg/jC8rtGdWScMuzzTENRgicfnr91C5 ......
dotnet 连接使用ef orm连接sqlite数据库的小demo
# `EF6SQLiteTutorial/Program.cs` ```cs using EF6SQLiteTutorial.Data; using Microsoft.EntityFrameworkCore; var builder = WebApplication.CreateBuilder(a ......
大数据生态圈/Hadoop/Spark/Flink/数据仓库/实时分析/推荐系统
课程实用性很强，老师讲的很透彻，都是面试容易问到的；紧扣当前企业所用技术，对于从事大数据或者转行大数据行业，都有很大的帮助。 比屋教育，秉承“活学活用”的教育理念，集合资深专家讲师团队，依托完善的线上教学管控平台，专注于大数据、云计算、互联网架构师等领域的职业技能培训，着力培养满足互联网企业实际需求 ......
创建Spring Boot+Spring MVC+Mybatis Demo项目
参考资料 IDEA搭建Springboot+SpringMVC+Mybatis+Mysql（详细、易懂） 创建项目 创建多个目录 把application.properties改成yml格式并补充配置 mysql中创建数据库和表 create database db1; use db1; creat ......
大数据Flink之基本架构
第二章 Flink基本架构 2.1 JobManager 与 TaskManager Flink 运行时包含了两种类型的处理器： JobManager 处理器：也称之为 Master，用于协调分布式执行，它们用来调度 task，协调检查点，协调失败时恢复等。Flink 运行时至少存在一个 maste ......
大数据Flink之概述
大数据课程之 Flink 第一章 概述 1.1 流处理技术的演变 在开源世界里，Apache Storm 项目是流处理的先锋。Storm 最早由 Nathan Marz和创业公司 BackType 的一个团队开发，后来才被 Apache 基金会接纳。Storm 提供了低延迟的流处理，但是它为实时性付 ......
flink demo
## 1. 搭建测试环境安装 ### 1.1 下载并启动docker-compose容器 ```bash # 该 Docker Compose 中包含的容器有： # DataGen：数据生成器。容器启动后会自动开始生成用户行为数据，并发送到 Kafka 集群中。默认每秒生成 1000 条数据，持续生 ......
flask demo
from flask import Flask, request from flask_cors import CORS app = Flask(__name__) CORS(app) @app.route('/') def index(): return '欢迎使用 Flask Demo 应用！' ......
dhtmlx基本使用demo，vue
main.js 引入样式 import 'dhtmlx-gantt/codebase/dhtmlxgantt.css' 父组件： gangtData，数据 <ganttChart v-if="value8" :gangtData="gangtData" /> 子组件： <template> <div ......
【Azure App Service】Web Job 报错 UNC paths are not supported. Defaulting to Windows directory.
问题描述 PHP的Web Job，通过artisan来配置路径启动PHP任务，相关启动脚本如下： artisan_path = "d:\\home\\site\\wwwroot"; cd ${artisan_path} echo "\n" pwd php artisan schedule:run 但 ......
golang的list数据结构demo
package mainimport "container/list"func main(){ var mylist list.List //放在尾部 mylist.PushBack("go") mylist.PushBack("grpc") mylist.PushBack("mysql") //头 ......
xxl-job部署
XXL-JOB安装、配置、启动、停止教程安装xxl-jobstep1：上传step2：解压step3：初始化数据库step4：修改xxl-job配置文件step4.1：修改调度中心配置文件application.propertiesstep4.2：修改logback.xml(配置xxl-job的日志 ......