-
编辑 删除
flink 有状态（stateful）的计算
flink在计算的时候可以将一个状态保存在计算过程中 在需要的时候来使用
-
编辑 删除
flink将bathch dataset 转换为sql操作
package flink.table_sql /*需要maven依赖 * org.apache.flink flink-tab
-
编辑 删除
flink connector 之FlinkKafkaProducer
flink connector 之FlinkKafkaProducer
-
编辑 删除
flink使用Event_time处理实时数据
flink使用Event_time处理实时数据
-
编辑 删除
flink 通过继承RichSinkFunction实现自定义sink,将数据录入数据库
//主类 package flink.streaming import java.util.Properties import org.apache.flink.streaming.api.scala._ import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer
-
编辑 删除
flink连接消费kafka
package flink.streamingimport java.util.Propertiesimport org.apache.flink.streaming.api.scala._import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerimport org.apache.flink.api.common.s
-
编辑 删除
flink batch dataset 的基本操作
flink 是可以通过文件名的前缀来识别文件系统的 如 file:///本地文件 hdfs://hadoop文件系统 s3:// s3的文件系统
