一. 什么是Table API1.1 Flink API总览首先：flink根据使用的便捷性提供了三种API，自下而上是： Table API & SQL 声明行：用户只关心做什么，不用关心怎么做 高性能：支持性能优化，...

1. 流处理基本概念对于什么是流处理，从不同的角度有不同的定义。其实流处理与批处理这两个概念是对立统一的，它们的关系有点类似于对于 Java 中的 ArrayList 中的元素，是直接看作一个有限数据集并用下标去访问，还是用迭代器去访...

从头开始，从设置Flink项目到在Flink集群上运行流分析程序。 Wikipedia提供了一个IRC频道，其中记录了对Wiki的所有编辑。我们将在Flink中读取此通道，并计算每个用户在给定时间窗口内编辑的字节数。这很容易使用Fli...

一、简述截至到目前(2019.04)，HBase 有两个主要的版本，分别是1.x 和 2.x ，两个版本的Java API有所不同，1.x 中某些方法在2.x中被标识为@deprecated过时。所以下面关于API的样例，我会分别给出...

一、创建DataFrame和Dataset1.1 创建DataFrameSpark中所有功能的入口点是SparkSession，可以使用SparkSession.builder()创建。创建后应用程序就可以从现有RDD，Hive表或S...

一、 简介想要使用HDFS API，需要导入依赖hadoop-client。如果是CDH版本的Hadoop，还需要额外指明其仓库地址： 1234567891011121314151617181920212223242526272829...

介绍在容器中获取 POD 的基本信息，kubernetes原生提供了支持，使用Downward API。 Downward API提供了两种方式用于将 POD 的信息注入到容器内部： 环境变量：用于单个变量，可以将 POD 信息和容...