Yarn工具类
分享一个java操作Yarn的工具类,使用的是Application模式,所有资源存储在hdfs上。包括以下
java操作Hdfs工具类
分享一个java操作Hdfs的工具类
SpringBoot动态数据源切换
SpringBoot动态数据源切换工具类,数据源信息可以保存在数据库中,根据需要运行时切换。
Flink自定义触发器
通过自定义flink触发器,根据数据条数或者数据字节数来控制Flink数据流的速度。
EasyRules规则引擎工具类
EasyRules是一款基于Java的开源的轻量级的规则引擎框架。EasyRules框架非常易于使用,且可以与任何Java应用程序无缝集成。在本文中,我们将对其进行一个简单的封装,以实现复杂的规则表达式匹配。
java时间表达式工具类
今天分享一个java中时间表达式的工具类,话不多说,直接上代码。以下代码是可以直接运行的。
flink反压问题及解决方案
当数据流入Flink的数据管道时,可能会出现数据量超过处理能力的情况,导致任务执行速度变慢或者甚至任务崩溃。这种情况称为背压(backpressure)问题。
java表达式语言-MVEL
MVEL表达式是一种基于Java语言的表达式语言,它提供了一种简单的方式来访问和操作Java对象,可以在Ja
使用Doris Flink Connector进行数据接入
Doris Flink Connector是一款高效的数据连接器,它能够将Apache Flink和DorisDB两个开源项目的优势结合起来,实现高效的数据接入和处理。本文将详细介绍如何配置和使用Doris Flink Connector。