共有1个答案
Ververica对Flink SQL的培训中有许多很好的例子--https://github.com/ververica/sql-training.这些示例使用Kafka源代码。
目前正在开发对数据库源的支持。Flink 1.11将增加对JDBC (Postgres)目录的支持。
-
通过stream API，我可以编写一个RichCoFlatMapFunction来接受一个控制流和一个数据流，控制流中包含了启动、停止或改变参数的计算元素，我知道我可以存储当前控制设置的状态，并在处理数据流时检查值。 但是用Flink SQL做类似的事情的方法是什么呢？我不能使用join，因为数据流和控制流不能连接在一起。 我们提出的解决方案是通过应用程序本身存储控件设置。其想法是： > 将控制
-
本文向大家介绍举例解析Java多线程编程中需要注意的一些关键点，包括了举例解析Java多线程编程中需要注意的一些关键点的使用技巧和注意事项，需要的朋友参考一下 1. 同步方法或同步代码块？ 您可能偶尔会思考是否要同步化这个方法调用，还是只同步化该方法的线程安全子集。在这些情况下，知道 Java 编译器何时将源代码转化为字节代码会很有用，它处理同步方法和同步代码块的方式完全不同。 当 JVM 执行一
-
我想知道这里的日常工作是如何进行的。 获取以下错误： *****我是主要的围棋套路***** 等待消息的主例程 goroutine 5[chan receive]: main.main.func1(0xC420054060) /users/work/go/src/github.com/golang_play/goroutine/goroutine.go:13+0x98由main.main/user
-
我这里有3个实体A、B和C。 实体A和实体B都与实体C有关系。在我的例子中，我有一个来自实体A的当前id，并且我想使用来自实体C的查询到达实体B。 多谢了。
-
现在，编辑器在使用注释方法的地方显示警告。然后显示使用的建议。当我接受它的更改时，它会将代码转换为此，警告消失。 使用有意义吗？ 实现是 所以如果为空，我的代码仍然会崩溃。 我们应该对此进行空检查。 我认为比好，你说呢？如果是，则编辑器不应建议在此处使用。 因为在具有状态（如）的字段中使用要求NonNull是不安全的。我是否错过了的一些好处？
-
我不明白，当我为5分配内存时，它会打印出一个示例。我知道可以使用strncpy来完成，但有没有一种方法可以不使用strncpy来完成呢 它适用于strncpy，但有没有办法在没有strncpy的情况下做到这一点？ 打印出一个示例 不应该打印OneE吗？？有人能解释一下吗？