一、HBaseShell操作1、基本操作1）进入HBase客户端命令行[root@bigdata1hbase]$bin/hbaseshell2）查看帮助命令hbase(main):001:0>help3）查看当前数据库中有哪些表hbase(main):002:0>list2、表的操作1）创建表hbase(main):002:0>create'student','info'2）插入数据到表hbase(main):003:0>put'student','1001','info:sex','male'hbase(main):004:0>put'student','1001','info:age','
异常现象1按照以下方式设置backend目录和checkpoint目录，fsbackend目录有数据，checkpoint目录没数据env.getCheckpointConfig().setCheckpointStorage(PropUtils.getValueStr(Constant.ENV_FLINK_CHECKPOINT_PATH));env.setStateBackend(newFsStateBackend(PropUtils.getValueStr(Constant.ENV_FLINK_STATEBACKEND_PATH)));原因我以为checkpoint和fsbackend要同时
1.hadoopfs-ls/ //查看根目录下的文件夹2.hadoopfs-mkdir/file //在根目录下创建file文件夹3.hadoopfs-put -f(覆盖目标文件）/-p(保留访问和修改时间，所有权和权限）a.hadoopfs-put /mnt/hello/scott/hello.txt //将本地mnt文件夹下的hello文件上传到hdfs的 scott文件夹下4.hadoopfs-ls/scott //查看scott文件夹 5.hadoopfs-get //从hdfs上下载文件到本地 a.hadoopfs-get/scott/hello.txt/mnt /
一、版本信息Flink：1.16.1二代码实现pom文件如下projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0http://maven.apache.org/xsd/maven-4.0.0.xsd">modelVersion>4.0.0modelVersion>groupId>com.wysgroupId>artifactId>flinka
弱口令爆破（Hydra）KaliLinux中的Hydra是一款强大的网络登录破解工具，它支持多种协议，如FTP、SSH、Telnet等。弱口令爆破是一种常见的网络攻击手段，通过尝试不同的用户名和密码组合来获取系统的访问权限。Hydra是一款强大的暴力破解工具，可以用于执行弱口令爆破。hydra中的一些基本参数1.主机（Host）：要尝试破解的目标主机的IP地址或域名。2.端口（Port）：目标主机上服务运行的端口号。3.协议（Protocol）：目标主机上服务使用的协议，如SSH、FTP等。4.服务类型（Service）：目标主机上服务的类型，如SSH服务的用户名枚举、密码破解等。5.攻击类型
【Flink-Kafka-To-RocketMQ】使用Flink自定义Sink消费Kafka数据写入RocketMQ1）准备环境2）代码实现2.1.主程序2.2.conf2.2.1.ConfigTools2.3.utils2.3.1.DBConn2.3.2.CommonUtils2.4.function2.4.1.MqSinkFunction2.5.resources2.5.1.appconfig.yml2.5.2.log4j.properties2.5.3.log4j2.xml1）准备环境这里的maven依赖比较冗余，推荐大家都加上，后面陆续优化。projectxmlns="http://m
Git常用命令tag和log和blame1、tag标签操作，常用于发布版本。1.1新建tag#新建一个tag在当前commit$gittagtag_name$gittagv1.0#新建一个tag在指定commit$gittagtag_namecommit$gittagv0.9f52c633#-a选项意为创建一个带注解的标签,不用-a选项也可以执行的,但它不会记录这标签是啥时候打的#谁打的,也不会让你添加个标签的注解$gittag-atag_name$gittag-av1.0#执行下面可以看到我们的标签$gitlog--decorate#创建带有说明的标签,用-a指定tag名,-m指定说明文字#
一、什么是状态无状态计算的例子：例如一个加法算子，第一次输入2+3=5那么以后我多次数据2+3的时候得到的结果都是5。得出的结论就是，相同的输入都会得到相同的结果，与次数无关。有状态计算的例子：访问量的统计，我们都知道Nginx的访问日志一个请求一条日志，基于此我们就可以统计访问量。如下，/api/a这个url第一此访问的时候，返回的结果就是count1，但当第二次访问的时候，返回的结果变成了2。为什么Flink知道之前已经处理过一次helloworld，这就是state发挥作用了，这里是被称为keyedstate存储了之前需要统计的数据，keyby接口的调用会创建keyedstream对ke
随着大数据应用的不断深入，企业不再满足离线数据加工计算的时效，实时数据需求已成为数据应用新常态。伴随着实时分析需求的不断膨胀，传统的数据架构面临的成本高、实时性无法保证、组件繁冗、运维难度高等问题日益凸显。为了适应业务快速迭代的特点，帮助企业提升数据生产和应用的时效性、进一步挖掘实时数据价值，实时数仓的构建至关重要。本文将分享如何基于ApacheDoris和ApacheFlink快速构建一个极速易用的实时数仓，包括数据同步、数据集成、数仓分层、数据更新、性能提升等方面的具体应用方案，在这之前，我们先可以先了解一下传统的数据架构如何设计的、又存在哪些痛点问题。#实时数仓的需求与挑战上图所示为传统
Flink系列之：ElasticsearchSQL连接器一、ElasticsearchSQL连接器二、创建Elasticsearch表三、连接器参数四、Key处理五、动态索引六、数据类型映射一、ElasticsearchSQL连接器Sink:BatchSink:StreamingAppend&UpsertModeElasticsearch连接器允许将数据写入到Elasticsearch引擎的索引中。本文档描述运行SQL查询时如何设置Elasticsearch连接器。连接器可以工作在upsert模式，使用DDL中定义的主键与外部系统交换UPDATE/DELETE消息。如果DDL中没有定义主键，那
