flink造数据

痛定思痛。 2024-03-03 07:38 35阅读 0赞

set execution.checkpointing.interval = 30s;
    set state.checkpoints.dir=hdfs://xxxx:8020/cluster/flink/checkpointes_;
    set state.savepoints.dir=hdfs://xxxx:8020/cluster/flink/savepointkes_;
    
    CREATE TABLE source_table (
                    userId INT,
                    age INT, 
                    balance DOUBLE,
                    userName STRING, 
                    t_insert_time AS localtimestamp,
                    WATERMARK FOR t_insert_time AS t_insert_time 
                    ) WITH (
                    'connector' = 'datagen', 
                    'rows-per-second'='5',
                    'fields.userId.kind'='sequence',
                    'fields.userId.start'='1',
                    'fields.userId.end'='5000',
                    'fields.balance.kind'='random',
                    'fields.balance.min'='1',
                    'fields.balance.max'='100',
                    'fields.age.min'='1',
                    'fields.age.max'='1000',
                    'fields.userName.length'='10'
                    );
    select * from source_table;

发表评论取消回复

表情：

评论列表（有 0 条评论，35人围观）

还没有评论，来说两句吧...

相关阅读

相关 flink造数据

set execution.checkpointing.interval = 30s; set state.checkpoints.dir=hdfs://xxx

痛定思痛。/ 2024年03月03日 07:38/ 0 赞/ 36 阅读

相关 fake造基础测试数据并用excle保存数据

1、安装fake库 pip install fake 2、复制代码 from pypinyin import lazy_pinyin from fake

逃离我推掉我的手/ 2022年12月20日 08:43/ 0 赞/ 122 阅读

相关大数据之Flink(3) | Flink部署

Standalone模式一.Standalone模式安装提交任务(手动代码或者网页) 一.Standalone模式安装

野性酷女/ 2022年12月15日 14:15/ 0 赞/ 159 阅读

相关大数据之Flink(1) | Flink简介

Flink简介一.Flink简介二.Flink的重要特点事件驱动型(Event-driven) 流与批的世界观

今天药忘吃喽~/ 2022年12月15日 14:13/ 0 赞/ 193 阅读

相关【Flink】使用Flink实现索引数据到Elasticsearch

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

谁践踏了优雅/ 2022年08月30日 04:11/ 0 赞/ 228 阅读

相关 ACM造数据+测数据

造数据： include<bits/stdc++.h> using namespace std; int main() {

末蓝、/ 2022年05月09日 05:56/ 0 赞/ 162 阅读

相关【Flink】Flink对于迟到数据的处理

代码地址：[https://github.com/18113996630/flink-practice/blob/master/src/main/scala/com/hrong

╰+攻爆jí腚メ/ 2022年04月25日 10:38/ 0 赞/ 277 阅读

相关造房子

造房子蒜头君最近迷恋上了一款游戏《我的世界（Minecraft）》，在游戏里面蒜头君可以任意开发资源然后建造各种宏伟的建筑。有一天蒜头君发现了一块荒野的土地

痛定思痛。/ 2022年03月17日 16:14/ 0 赞/ 161 阅读

相关 flink消费kafka数据

maven配置 <dependency> <groupId>org.apache.flink</groupId> <artifa

偏执的太偏执、/ 2022年02月28日 08:36/ 0 赞/ 323 阅读

相关【Flink入门】Flink读取Kafka数据Demo

flink算子操作主要分为三大部分：source(数据读取)、transform(数据处理)、sink(数据输出)，这篇博客简单聊聊flink读取kafka数据在控制台打印的D

超、凢脫俗/ 2021年09月25日 04:40/ 0 赞/ 630 阅读