ALTER 语句 执行 ALTER 语句 ALTER TABLE ALTER DATABASE ALTER FUNCTION ALTER 语句 ALTER 语句用于修改一个已经在 Catalog 中注册的表、视图或函数定义。 Flink SQL 目前支持以下 ALTER 语句： ALTER TABLE ALTER DATABASE A...

DataSource Client SDK 的使用 1. 引入依赖模块 2. Scala测试代码 DataSource Client SDK 的使用 Linkis DataSource 提供了方便的JAVA和SCALA调用的接口，只需要引入linkis-datasource-client的模块就可以进行使用， 1. 引入依赖模块 <d...

Iterator类的操作 带缓冲的迭代器 迭代器不是一个容器，更确切的说是逐一访问容器内元素的方法。迭代器it的两个基本操作是next和hasNext。调用it.next()会返回迭代器的下一个元素，并且更新迭代器的状态。在同一个迭代器上再次调用next，会产生一个新元素来覆盖之前返回的元素。如果没有元素可返回，调用next方法会抛出一个NoSuchE...

Table API 概述 & 示例 Operations Scan, Projection, and Filter From FromValues Select As Where / Filter 列操作 AddColumns AddOrReplaceColumns DropColumns RenameColumns Aggregat...

Table API 概述 & 示例 Operations Scan, Projection, and Filter From FromValues Select As Where / Filter 列操作 AddColumns AddOrReplaceColumns DropColumns RenameColumns Aggregat...

UDF 的使用 1 UDF简介 2 UDF增删改 2.1 UDF新增 2.2 UDF修改 2.3 UDF删除 3 UDF使用 4 UDF共享 5 其他功能介绍 5.1 UDF移交 5.2 UDF过期 5.3 UDF版本列表 UDF 的使用 1 UDF简介 UDF：User Defined Function，用户自定义函数。某些场...

开始翻滚吧! 开始翻滚吧! 祝贺你成功运行你的第一个 Spark 应用程序! 要深入了解 API，可以从Spark编程指南 开始，或者从其他的组件开始，例如：Spark Streaming。 要让程序运行在集群(cluster)上，前往部署概论 。 最后，Spark 在 examples 文件目录里包含了 Scala , Java 和 Pyt...

A Demo using docker containers Prerequisites Setting up Docker Cluster Build Hudi Bringing up Demo Cluster Demo Step 1 : Publish the first batch to Kafka Step 2: Incrementally...

Testing Testing User-Defined Functions Unit Testing Stateless, Timeless UDFs Unit Testing Stateful or Timely UDFs & Custom Operators Unit Testing ProcessFunction Testing Flink ...

Testing Testing User-Defined Functions Unit Testing Stateless, Timeless UDFs Unit Testing Stateful or Timely UDFs & Custom Operators Unit Testing ProcessFunction Testing Flink ...