flink造数据

痛定思痛。 2024-03-03 07:38 48阅读 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 条评论，48人围观）

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

相关阅读

相关记录造数据测试接口

一、前言在java开发中经常需要造数据进行测试接口，这里记录一下常用的通过造数据测试接口的方法。 ![34065bfb64bf44faab1e3ca1f11f129a.p

淩亂°似流年/ 2024年03月03日 08:02/ 0 赞/ 61 阅读

相关 flink造数据

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

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

相关 flink读取kafka数据

前言在实际生产环境中，经常需要使用flink读取外部的数据源作为数据的输入流，其中kafka就是重要的实时数据源，flink可以通过消费kafka指定的topic数据达

不念不忘少年蓝@/ 2023年10月02日 17:39/ 0 赞/ 25 阅读

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

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

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

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

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

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

相关 ACM造数据+测数据

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

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

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

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

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

相关造房子

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

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

相关 flink消费kafka数据

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

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

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

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

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