28 9 月 Flink, 大数据 Posted by 蓝染君 flink-41 常用Connector读写 需要注意 服务器上 flink客户端依赖和idea中编码依赖有不同 Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-40 Module操作 Module允许flink扩展函数能力 目前flink包含了以下三种module: Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-37 Flink sql 时间属性 所谓的时间属性,其实就是每个表schema的一部分,它可以在创建表的DDL里直接定义一个字段,也可以在DataStream转换成表时定义。 Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-36 流处理中的表 动态表(Dynamic Tables) 当流中有新数据到来,初始表中会插入一行,而基于这个表定义的SQL查询,就应该在之前的基础上更新... Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-34 状态一致性 端到端一致性 状态一致性 一致性其实就是结果的正确性,一般从数据丢失、数据重复来评估 Continue reading
28 9 月 Flink, 大数据 Posted by 蓝染君 flink-33 保存点 除了检查点,flink还提供了另一个非常独特的镜像保存功能:保存点(savepoint) 这也时一个存盘的备份,原理和算法与检查点完全... Continue reading