Side Outputs Side Outputs In addition to the main stream that results from DataStream operations, you can also produce any number of additional side output result streams. The ...

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

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...

功能矩阵 第三方客户端 Pulsar 支持以下客户端库： Java 客户端 Go client Python client C++ client Node.js 客户端 WebSocket 客户端 C# client 功能矩阵 Pulsar client feature matrix for different language...

Java 兼容性 当我们写的Scala代码被Java调用时，我们要确保从Java来用仍然习惯。这常常不需要额外的努力——class和纯的trait等价于Java的中的对应类型 —— 但有时需要提供独立的Java API。一种感受你的库中的Java API好的方式是用Java写单元测试(只是为了兼容性);这也确保了你的库中的Java视图保持稳定，在这一点上...

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，用户自定义函数。某些场...

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，用户自定义函数。某些场...

DataStream API 简介 什么能被转化成流？ Java tuples 和 POJOs Tuples POJOs Scala tuples 和 case classes 一个完整的示例 Stream 执行环境 基本的 stream source 基本的 stream sink 调试 动手实践 更多阅读 DataStrea...

使用 Docker Compose 快速构建集群 准备环境 快速部署 自定义集群 访问 Spark shell 并加载 TiSpark 使用 Docker Compose 快速构建集群 本文档介绍如何在单机上通过 Docker Compose 快速一键部署一套 TiDB 测试集群。 Docker Compose 可以通过一个 YAML 文...