“基于Table API 实现实时报表”官网示例，完整实现

﹏ヽ暗。殇╰゛Y 2022-11-01 13:46 137阅读 0赞

##### 1.官网完整说明 #####

https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/try-flink/table\_api.html

##### 2.完整源码（解决各种bug） #####

https://download.csdn.net/download/taotao\_guiwang/15450139

##### 3.kafka发送数据 #####

*  kafka创建主题  
    kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic transactions
 *  查看已创建的主题  
    kafka-topics.bat --list --zookeeper localhost:2181
 *  使用kafka生产者工具发送数据  
    cd D:\\kafka\_2.12-0.10.2.1\\bin\\windows  
    kafka-console-producer.bat --broker-list localhost:9092 --topic transactions
 *  示例数据  
    1,1,2021-2-22 20:00:00.111  
    每输入一行点击回车，数据发送到kafka。  
    ![在这里插入图片描述][20210224170213790.png]

##### 4.数据库表结构 #####

SET NAMES utf8mb4;
    SET FOREIGN_KEY_CHECKS = 0;
    -- ----------------------------
    -- Table structure for spend_report
    -- ----------------------------
    DROP TABLE IF EXISTS `spend_report`;
    CREATE TABLE `spend_report`  (
      `account_id` bigint(20) NOT NULL,
      `log_ts` timestamp(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3) ON UPDATE CURRENT_TIMESTAMP(3),
      `amount` bigint(20) NULL DEFAULT NULL,
      PRIMARY KEY (`account_id`, `log_ts`) USING BTREE
    ) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_bin ROW_FORMAT = Dynamic;

##### 5.最终分析结果 #####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Rhb3Rhb19ndWl3YW5n_size_16_color_FFFFFF_t_70]

[20210224170213790.png]: /images/20221024/c956e8bc154e49d2897fc9d63e3cd2cb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Rhb3Rhb19ndWl3YW5n_size_16_color_FFFFFF_t_70]: /images/20221024/316813e320744d7da5baff6b8774c9ee.png