FlinkUI界面
flinkUI界面
大数据下的竞彩足球胜平负分析技巧2
上期内容分析、证明了竞彩官方终赔时，当主队让1球同时又满足：让负赔率>平负均值赔率的情况出现了6胜3平1负，说明了竞彩官方给出的让负过大条件下并不利于客队打出，此时近十场中主不败概率90%，其中主胜的概率为60%，
doris配置hive的catalog
查询hive的database。创建hive的catalog。
用sqoop导出hive parquet 分区表到mysql
Sqoop默认只导出分区表的一个分区。如果你想要导出分区表的所有分区，可以使用–hive-partition-key参数指定分区键，并结合Sqoop的–warehouse-dir参数指定Hive表的根目录。替换 <mysql_host>、<database_name>、<mysql_username
【JavaEE初阶】——第七节.Servlet入门学习笔记
今天我们将进入到Servlet的认识当中，Servlet对于我们后面项目的创建编写有着非常重要的作用，需要我们能够非常熟练的掌握他；
kafka消费者api和分区分配和offset消费
消费者的消费方式为主动从broker拉取消息，由于消费者的消费速度不同，由broker决定消息发送速度难以适应所有消费者的能力拉取数据的问题在于，消费者可能会获得空数据。
Spring-Kafka如何实现批量消费消息并且不丢失数据
某个业务对象由多张表关联而成，要创建该对象需要想多张表插入数据，基于canal的监控就会有多次该对象的变更记录，而Kafka消费的时候也会多次处理同一个对象（虽然不同表，但是同一个对象的不同部分），原有的Kafka消费者是一次处理一条，这将造成重复对同一个对象的处理。其实只需要所有表插入完毕后，一次
腾讯云对象存储联合DataBend云数仓打通数据湖和数据仓库
伴随多场景的成功落地，腾讯云对象存储打造基于云技术的湖仓一体解决方案。将数据仓库构建在数据湖上，打通数据仓库和数据湖两套体系，构建以数据湖为中心，融合数据仓库、大数据、AI等技术的生态体系，既有数据湖的灵活性和可扩展性，又有数据仓库的数据管理功能。
Zookeeper简介及核心概念
Zookeeper 是一个开源的分布式协调服务，目前由 Apache 进行维护。Zookeeper 可以用于实现分布式系统中常见的发布/订阅、负载均衡、命令服务、分布式协调/通知、集群管理、Master 选举、分布式锁和分布式队列等功能。顺序一致性：从一个客户端发起的事务请求，最终都会严格按照其发起
Kafka数据丢失原因及解决方案
Producer端、Broker端、Consumer端丢失数据及解决方法
大数据的金融数据读取及分析（二）
大数据的金融数据读取及分析（二） 获取数据，导出为excel,ps:高校学生可联系站方申请访问权限。在这里可通过旧版接口访问指数信息。新版接口为tushare pro
Kettle变量和参数介绍系列文章3-循环的轻松实现
本文详细说明两种实现循环操作的方法，0编程经验的人也可以看懂，使用Kettle做数仓工具的可以看一下。
DataX的使用与介绍（1）
一、什么是DataX？DataX是阿里云商用产品DataWorks数据集成的开源版本，它是一个异构数据源的离线数据同步工具/平台（ETL工具）。DataX实现了包括Mysql，Oracle、OceanBase、Sqlserver，Postgre、HDFS、Hive、ADS、HBase、TableSt
Flink的流处理和人工智能：将人工智能融入流处理
作者：禅与计算机程序设计艺术 Flink的流处理和人工智能：将人工智能融入流处理作为一位人工智能专家，程序员和软件架构师，我深知流处理的重要性和价值。流处理是一种高并行、高可扩展性的数据处理方式，能够大大提高数据处理的速度和效率。同时，结合人工智能技术，可以
拉链表的制作过程
**背景：**对于一些维度表，数据量特别大，每天又会有新增或者修改的数据，但是这部分数据总数据量的比重不大。如果做成每日全量数据，会导致大量的重复数据，占用存储资源；如果做成全量最新，则会缺少历史数据。针对这种情况，可以考虑使用拉链表。**设计思路：**每行数据加上两个字段，开始时间，结束时间。初始
九、数据仓库详细介绍（元数据）
元数据（Meta-data）是描述数据的数据（The data about data），更准确点应该叫 The information abut data。如何理解这句话？就是描述信息、实体、系统的数据。举几个例子175，大家有概念吗？如果我说这是一个男孩儿的身高大家是不是就懂了。如果我再加一个他才
常用的Prestosql
常用的Prestosql
RabbitMQ到底为什么要使用它？
Message Queue，消息队列，是基础数据结构中“先进先出”的一种数据结构。把要传输的消息（数据）放在队列中，用队列机制来实现消息传递——生产者生产消息把消息放入队列，然后消费者去处理。消费者可以到指定队列拉取消息，或者订阅响应的队列，由MQ服务端给其推送消息。本次先对MQ和衍生出来的Rabb
skywalking agent使用kafka数据传输
Skywalking agent高并发场景下信息上传
腾讯云大数据型CVM服务器实例D3和D2处理器CPU型号说明
腾讯云服务器CVM大数据型D3和D2处理器型号，大数据型D3云服务器CPU采用2.5GHz Intel® Xeon® Cascade Lake 处理器，大数据型D2云服务器CPU采用2.4GHz Intel® Xeon® Skylake 6148 处理器。腾讯云服务器网分享云服务器CVM大数据型CP
