作者小头像 Lv.4
更多个人资料
795 成长值
2 关注
4 粉丝
+ 关注 私信

个人介绍

这个人很懒，什么都没有留下

感兴趣或擅长的领域

大数据、云存储、数据库
个人勋章
TA还没获得勋章~
成长雷达
760
15
0
0
20

个人资料

个人介绍

这个人很懒，什么都没有留下

感兴趣或擅长的领域

大数据、云存储、数据库

达成规则

以上满足项可达成此勋章

  • 博客
  • 关注
  • 粉丝
  • 论坛
全部时间
全部时间
最近三天
最近一周
最近一月
  • 全部
  • 暂无专栏分类
念念不忘，必有回响：2022，我在华为云的日子
2022，我在华为云的日子2022年，我在华为云度过了一个美好的一年。在这一年里，我取得了很多成就，也学到了很多东西。首先，我在华为云参与了一系列的项目，包括云计算、大数据、人工智能等，这些项目都是华为云的核心业务，我在这些项目中取得了很大的进步，提升了自己的技术水平。其次，我在华为云参与了一系列的技术培训，包括云计算、大数据、人工智能等，这些培训让我更加深入地了解了华为云的技术，也更加熟...
大数据
作者小头像 Maynor学长 2022-12-30 17:12:58
3201
0
0
2022-12-30 17:12:58
999+
0
0
Flink证券项目(七)数据采集
项目进度： 1. 数据采集 1.1. 沪市行情实时文本数据采集沪市行情服务端会在交易时间段内对外实时广播行情数据，实时行情数据以txt文本的形式写入存储网关(FTP服务)，这里我们采用Flume自定source的方式实时采集FTP服务器上的行情数据源。 1.1.1. 沪市采集数据流程 1.1.2. 导入依赖<dependency> <groupId>org.apache.flume</gro...
Flink 证券行情资讯
作者小头像 Maynor学长 2022-11-25 15:32:31
8039
0
0
2022-11-25 15:32:31
999+
0
0
Flink证券项目(六) 客户端程序
客户端程序客户端负责接收服务端广播的实时行情数据，并对数据预处理加工，发送到消息队列Kafka中。1.获取服务端数据在cn.itcast.szse包下创建客户端接收数据对象：SocketClient开发步骤:1.创建main方法2.建立socket连接，获取流数据3.读文件缓存成交量和成交金额4.解析行数据，数据转换发送kafka代码略2.读取文件缓存成交数据解析文件获取成交量和成交金额数...
Flink 证券行情资讯
作者小头像 Maynor学长 2022-11-25 15:32:02
7176
0
0
2022-11-25 15:32:02
999+
0
0
Flink证券项目(五) 实时流数据采集
1.1. 实时流数据采集 1.1.1. 创建数据采集工程 1.1.1.1. 1.创建子工程此阶段采集的数据为深市实时行情数据，深市行情是已socket的方式对外广播行情数据。新建数据采集工程，在父类下新建子工程-producer： 1.1.1.2. 2.创建项目包目录结构包名说明cn.itcast.util工具类cn.itcast.avroavro对象cn.itcast.sse沪市数据采集...
Flink 证券行情资讯
作者小头像 Maynor学长 2022-11-25 15:31:29
7186
0
0
2022-11-25 15:31:29
999+
0
0
Flink证券项目(三) 数据源
1.1. 数据源 1.1.1. 实时数据源接口 1.1.1.1. 文本数据上证行情数据接口文档文件名：竞价行情文件（sse.txt）接收方：[新债券业务管理系统,新公司业务管理系统,行情监测系统,期权风控系统,指数公司,信息中心,信息公司,港交所,新基金业务管理系统]功能描述：本文件为行情文件接口。对于竞价撮合平台，行情文件名为sse.txt，当日开市至交易结束期间实时发送。产品类型：债券...
Flink 证券行情资讯
作者小头像 Maynor学长 2022-11-24 15:48:33
3878
0
0
2022-11-24 15:48:33
999+
0
0
Flink证券项目(二)技术架构
1.1. 技术架构 1.1.1. 逻辑架构逻辑架构关注的是业务功能，包含用户直接可见的功能，偏向于业务概括。逻辑架构也可以用“分层”的概念来理解，比如，把一个项目分为“显示层、应用层、分析计算层、数据访问层”等。数据源区数据源包括公司内部、外部的数据，数据包括业务系统产生的结构化数据（交易、账户、客户、外部数据等）、半结构化数据（XBRL数据、日志数据等）以及非结构化数据。大数据平台区大数...
Flink 证券行情资讯
作者小头像 Maynor学长 2022-11-24 15:47:37
7115
0
0
2022-11-24 15:47:37
999+
0
0
Flink证券项目(一)业务介绍
1. 证券业务介绍证券是多种经济权益凭证的统称，因此，广义上的证券市场指的是所有证券发行和交易的场所，狭义上，也是最活跃的证券市场指的是资本证券市场、货币证券市场和商品证券市场。证券市场是股票、债券、商品期货、股票期货、期权、利率期货等证券产品发行和交易的场所。行情项目相关业务的开发和实施需要我们提前了解一些证券方面的业务知识，比如说开盘价、收盘价、成交额、涨跌等。证券业务知识可参见资料：...
Flink 证券行情资讯
作者小头像 Maynor学长 2022-11-24 15:46:46
7287
0
0
2022-11-24 15:46:46
999+
0
0
Flink证券项目(四) 高性能数据传输中间件
1.1. 高性能数据传输中间件在企业级大数据流处理项目中，往往在项目数据源处需要面临实时海量数据的采集。采集数据的性能一般与网络带宽、机器硬件、数据量等因素有直接关系；当其他因素是固定的，这里我们只考虑数据量的话，那么数据量的传输和存储性能是我们首先需要面对和解决的。由此我们引入了Avro数据序列化框架，来解决数据的传输性能问题。 1.1.1. Apache Avro介绍Apache Av...
Flink 证券行情资讯
作者小头像 Maynor学长 2022-11-24 15:46:10
3231
0
0
2022-11-24 15:46:10
999+
0
0
实时即未来，大数据项目车联网之合并分析电子围栏结果（22）
1. 合并分析电子围栏结果 1.1 读取电子围栏分析结果表数据并广播l 读取电子围栏分析结果表：electric_fence，并广播传递给下一个任务节点l 自定义source，继承RichSourceFunction对象，重写run、cancel方法l 获得已存在结果表中的车辆和最早出现在结果表中的id，并广播结果流l 主类实现电子围栏分析第5大步//TODO 5.读取电子围栏分析结果...
大数据 车联网
作者小头像 Maynor学长 2022-10-31 12:41:13
7269
0
0
2022-10-31 12:41:13
999+
0
0
实时即未来，大数据项目车联网之电子围栏模型使用翻滚窗口（21）
theme: smartblue持续创作，加速成长！这是我参与「掘金日新计划 · 10 月更文挑战」的第21天，点击查看活动详情 1. 电子围栏模型使用翻滚窗口l 创建90秒翻滚窗口，计算中电子围栏信息(ElectricFenceModel中的值根据车辆是否在围栏内进行设置)n 设置电子围栏水印n 根据vin进行分组n 创建翻滚窗口，90秒为一个窗口周期n 自定义窗口函数，计算电子围栏中...
交通智能体
作者小头像 Maynor学长 2022-10-31 12:37:36
6986
0
0
2022-10-31 12:37:36
999+
0
0
总条数：110
10
10
20
50
100
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • ...
  • 11

上滑加载中

https://www.baidu.com/s?ie=utf-8&f=3&rsv_bp=0&rsv_idx=1&tn=baidu&wd=sed%20%E6%9B%BF%E6%8D%A2%E5%AD%97%E7%AC%A6%E4%B8%B2&rsv_pq=c7db61a600035dc5&rsv_t=5e19yEsbV9N5fIvdlGRU
作者小头像
作者小头像
快速交付
+ 关注