上一节知道了TableEnvironment的作用,并且也知道了创建TableEnvironment有两种方法… 继续阅读 Flink从入门到实战九[Table API&SQL]-3-使用EnvironmentSettings创建 TableEnvironment
月度归档: 2022年8月
Flink从入门到实战九[Table API&SQL]-2-什么是 TableEnvironment
TableEnvironment 是 Table API 和 SQL 的核心概念。它负责: • 在内部的 ca… 继续阅读 Flink从入门到实战九[Table API&SQL]-2-什么是 TableEnvironment
Flink从入门到实战九[Table API&SQL]-1-什么是 Table API&SQL?
Flink本身是批流统一的处理框架,所以Table API和SQL,就是批流统一的上层处理API。目前功能尚未… 继续阅读 Flink从入门到实战九[Table API&SQL]-1-什么是 Table API&SQL?
Flink从入门到实战八[State]-17-Flink状态 RocksDBStateBackend使用
EmbeddedRocksDBStateBackend 将正在运行中的状态数据保存在 RocksDB 数据库中… 继续阅读 Flink从入门到实战八[State]-17-Flink状态 RocksDBStateBackend使用
Flink从入门到实战八[State]-16-Flink State Backend 状态后端
Checkpoint的作用是将状态持久化,State Backend(状态后端)则是真正管理状态、存储状态、基… 继续阅读 Flink从入门到实战八[State]-16-Flink State Backend 状态后端
Flink从入门到实战八[State]-15-Flink状态 SavePoint使用
什么是 SavepointSavepoint 是依据 Flink checkpointing 机制所创建的流作… 继续阅读 Flink从入门到实战八[State]-15-Flink状态 SavePoint使用
Flink从入门到实战八[State]-14-Flink状态 Checkpoint使用
上一节了解了Checkpoint的执行流程和内部原理,那么Checkpoint是如何使用的呢,我们先来看一下A… 继续阅读 Flink从入门到实战八[State]-14-Flink状态 Checkpoint使用
Flink从入门到实战八[State]-13-Flink状态容错
前面几节内容已经演示了如何使用Flink状态进行计算,如何对状态进行保存、恢复。要实现状态的应用计算和保存恢复… 继续阅读 Flink从入门到实战八[State]-13-Flink状态容错
SpringBoot使用@Value进行配置信息绑定,报错:no matching editors or conversion strategy found
SpringBoot使用@Value进行配置信息绑定,SpringBoot项目启动报错:no matching… 继续阅读 SpringBoot使用@Value进行配置信息绑定,报错:no matching editors or conversion strategy found
Java compare方法比较时,报错:xxx cannot be cast to java.lang.String
代码: 原因重点代码在这里:return instance.compare(o1,o2); 使用compare… 继续阅读 Java compare方法比较时,报错:xxx cannot be cast to java.lang.String
使用Java8的Comparator对单个和多个属性进行排序
使用Java8的Comparator进行排序,代码会显得非常简洁,不用像传统方式自定义一个类或定义一个匿名内部… 继续阅读 使用Java8的Comparator对单个和多个属性进行排序
使用Java8的Comparator对汉字进行排序
Comparator类从Java 1.2版本就已经有了,在Java8开始,加入了适用于Lambda的一些方法,… 继续阅读 使用Java8的Comparator对汉字进行排序
SpringBoot使用自定义线程池并发编程
在SpringBoot或Spring中使用并发编程变得很简单了,如果开发者不定义线程池,SpringBoot或… 继续阅读 SpringBoot使用自定义线程池并发编程
SpringBoot使用默认线程池并发编程
在SpringBoot或Spring中使用并发编程变得很简单了,如果开发者不定义线程池,SpringBoot或… 继续阅读 SpringBoot使用默认线程池并发编程
List、ArrayList执行subList报错:IndexOutOfBoundsException
List、ArrayList执行subList报错: 问题很明显是下标越界,错误代码: API使用的问题在于s… 继续阅读 List、ArrayList执行subList报错:IndexOutOfBoundsException