标签:Flink
报告(Reporter) 通过 conf/flink-conf.yaml 文件配置一个或多个 Reporter […]
Flink 自带一个度量系统,允许收集和公开指标到外部系统。 注册指标 可以通过继承 RichFunction […]
Window Join(窗口连接) Window Join 连接共享公共 Key 并位于同一窗口中的两个流的数 […]
Flink 的 Table API 和SQL支持是用于批处理和流处理的统一API。这意味着 Table API […]
Apache Flink 具有两个关系型API:Table API 和SQL,用于统一流和批处理。 Table […]
机器学习和图计算应用,都会使用到迭代计算,Flink 通过在迭代算子中定义 Step 函数来实现迭代算法,迭代 […]
Data Source Data Source 创建初始数据集。Flink 附带了几种内置输入格式,可以从通用 […]
Data Sources 源是程序读取输入数据的位置。可以使用 StreamExecutionEnvironm […]