Skip To Main Content
Order TimeSeries BIGINT on Muck Rack

Order TimeSeries BIGINT

As seen in: CSDN
Is this you? As a journalist, you can create a free Muck Rack account to customize your profile, list your contact preferences, and upload a portfolio of your best work. Claim your profile

Get in touch with Order TimeSeries

Contact Order TimeSeries, search articles and posts on X, monitor coverage, and track replies from one place.

Learn more about Muck Rack

Actions

Share this page

Is this you?

As a journalist, you can create a free Muck Rack account to customize your profile, list your contact preferences, and upload a portfolio of your best work.
Claim your profile

Articles

Flink 系例之 SQL 案例 - 订单统计

|
By userName STRING, goodsType STRING, orderTime STRING, Order TimeSeries BIGINT
| CSDN
本期示例： 将对电商实时订单进行聚合计算，分以下两个维度进行： 1. 统计每 1 分钟的订单数量、用户数量、销售额、商品数 2. 统计每个分类的订单总数量、用户总数量（未去重）、销售额、商品数 流程说明： 1. 通过模拟电商平台订单简要数据，向 Kafka 消息队列中推送 mq 数据； 2. 通过 flink 集群，建立 SQL 流批处理任务； 3.Kafka 做为 SQL 数据流的输入源，并建立 source 数据表； 4. 通过 SQL 建立查询视图，将聚合算子的结果通过视图输出； 5.Mysql 做为 SQL 数据流的输出源，并建立 sink 数据表； 6. 执行 insert 操作，并在 flink 集群中建立 Task Job 任务，将聚合结果视图输出到 sink 表； 操作过程 1. 前期准备工作 1. 搭建 Flink 集群，保持集群可用，并处于启动状态 2. 开启 flink-sql-client 客户端 3. 搭建 Kafka 消息队列中间件服务，并启动服务，保持 9092 端口可连接 4. 创建 mysql 数据库相关表 5.
Open in Who Shared Issue with article?
See all 1 articles