大数据

并行度设置&优先级 并行度（Parallelism） 并行度的设置 在Flink中，可以用不同的方法来设置并行度，它们的有效范围和优先级别也是不同的。 代码中设置 我们在代…

随着大数据技术的快速发展，大数据信用报告在个人信用评估中发挥着越来越重要的作用。然而，对于很多人来说，大数据信用报告仍然是一个相对陌生的概念。本文将就大数据信用报告的查询频率和查询…

安装kibana 报错 1，elasticsearch.yaml 和kibana.yaml 配置问题 2，elasticsearch 和kibana版本不一致 3，索引问题 1，e…

State Backends 由 Flink 管理的 keyed state 是一种分片的键/值存储，每个 keyed state 的工作副本都保存在负责该键的 taskmanag…

一、HBase简介 1.1、HBase是什么 Google在200-2006发表了GFS、MapReduce、BigTable三篇 论文 ，号称“三驾马车”，开启了大数据的时代。 …

本文介绍Flume监听本地文件采集数据流到HDFS 我还写了一篇文章是Flume监听端口采集数据流到Kafka【点击即可跳转，写的也非常详细】 任务一： 在Master节点使用Fl…

目录 实验3  熟悉常用的HBase操作 一、实验目的 二、实验平台 三、实验步骤（每个步骤下均需有运行截图） （一）编程实现以下指定功能，并用Hadoop提供的HBase She…

《Flink SQL 语法篇》系列，共包含以下 10 篇文章： Flink SQL 语法篇（一）：CREATE Flink SQL 语法篇（二）：WITH、SELECT &…

系列文章目录 ZOOKEEPER和KAFKA的配置 文章目录 系列文章目录 ZOOKEEPER和KAFKA的配置 一、ZOOKEEPER是什么？ 二、KAFKA是什么？ 三、基本配…