上一节知道了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