本文脚本修改自github上的一个脚本。环境为MacOS-Arm版 1.创建一个目录 mkdirmagisk-sh 2.下载Magiskapk 可以去github上下载，链接：https://github.com/topjohnwu/Magisk/releases本文采用v26.1版本下载完成之后，可以直接拖入模拟器中安装还需要将magiskapk文件放入刚才创建的目录中 3.编写脚本 脚本后缀名为.sh脚本仅供参考，有些地方需要修改 修改APILEVEL为自己的 修改APK为自己的，注意要有版本号，没有要修改一些东西 修改RAMDISK，如果是从AndroidStudio中下载的sdk和...

在实时数据处理领域，ApacheFlink已成为一个不可或缺的工具。它以其高吞吐量和低延迟处理能力而闻名。而在Flink的众多特性中，侧输出流（SideOutputs）提供了一种灵活的方式来处理复杂的数据流。本文将探讨如何在Flink的ScalaAPI中有效使用侧输出流。 1.侧输出流的基本概念 侧输出流是一种特殊类型的输出流，它允许您从主数据流中分离出特定的事件或数据。与主流相比，侧输出流用于处理异常数据、监控事件或分流特殊数据，从而使主数据流保持清晰和高效。 2.ScalaAPI中实现侧输出流 让我们通过一个简单的例子来了解如何在Flink的ScalaAPI中实现侧输出流： importo...

在ApacheFlink中实现高效的TopN数据处理，尤其是涉及时间窗口和多条件排序时，需要精细地控制数据流和状态管理。 普通计算TopN： 1.定义数据源（Source） 首先，我们需要定义数据源。这可能是Kafka流、文件、数据库或任何其他支持的数据源。 valstream:DataStream[YourType]=env.addSource(...) 2.定义业务逻辑（Transformation） 接下来，我们需要根据业务需求对数据进行转换。这可能包括映射、过滤、聚合等操作。 valtransformedStream:DataStream[YourTransformedType]=...

一、HBaseShell操作 1、基本操作 1）进入HBase客户端命令行 [root@bigdata1hbase]$bin/hbaseshell 2）查看帮助命令 hbase(main):001:0>help 3）查看当前数据库中有哪些表 hbase(main):002:0>list 2、表的操作 1）创建表 hbase(main):002:0>create'student','info' 2）插入数据到表 hbase(main):003:0>put'student','1001','info:sex','male' hbase(main):004:0>...

Flink中的处理函数（ProcessFunction和KeyedProcessFunction）在对于数据进行颗粒化的精确计算时使用较多，处理函数提供了一个定时服务（TimerService），可以向未来注册一个定时服务，我们可以把它理解为一个闹钟，当闹钟响起时，就调用ProcessFunction中的onTimer()方法，会对数据进行一些计算。我们来解析一下这两个函数。 本文基于Flink1.14版本 ProcessFunction ProcessFunction是Flink中的较为底层的API，当我们对于DataStream调用process函数的时候，需要在里面传入一个对象，即new...