榜单
IT文库
服务器优惠
-
Overview
Data Types & Serialization Supported Data Types Tuples and Case Classes POJOs Primitive Types General Class Types Values Hadoop Writables Special Types Type Erasure & Type I... -
Data Types
Data Types Data Type Data Types in the Table API Physical Hints List of Data Types Character Strings CHAR VARCHAR / STRING Binary Strings BINARY VARBINARY / BYTES Ex... -
Data Types
Data Types Data Type Data Types in the Table API Physical Hints List of Data Types Character Strings CHAR VARCHAR / STRING Binary Strings BINARY VARBINARY / BYTES Ex... -
编译这个例子
编译这个例子 编译这个例子 我们用 Scala 编译器scalac 来编译这个例子。scalac 就像大多数编译器一样，它接受源代码文件当对象，并接受额外的选项，然后产生一个或多个对象文件。它产出的对象文件为标准 Java class 文件。 如果我们将上面的程序存为文件HelloWorld.scala ，编译指令为(> 是提示字符，不用打)：... -
11.03 json 模块：处理 JSON 数据
json 模块：处理 JSON 数据 JSON 基础 JSON 与 Python 的转换 生成和读取 JSON 文件 json 模块：处理 JSON 数据 JSON (JavaScript Object Notation) 是一种轻量级的数据交换格式，易于人阅读和编写，同时也易于机器解析和生成。 JSON 基础 JSON 的基础结构有两种... -
Catalogs
Catalogs Catalog 类型 GenericInMemoryCatalog JdbcCatalog HiveCatalog 用户自定义 Catalog 如何创建 Flink 表并将其注册到 Catalog 使用 SQL DDL 使用 Java/Scala Catalog API 数据库操作 表操作 视图操作 分区操作 函数操... -
Catalogs
Catalogs Catalog 类型 GenericInMemoryCatalog JdbcCatalog HiveCatalog 用户自定义 Catalog 如何创建 Flink 表并将其注册到 Catalog 使用 SQL DDL 使用 Java/Scala Catalog API 数据库操作 表操作 视图操作 分区操作 函数操... -
概览
算子 数据流转换 Map DataStream → DataStream FlatMap DataStream → DataStream Filter DataStream → DataStream KeyBy DataStream → KeyedStream Reduce KeyedStream → DataStream Window ... -
简单例子：Hello World
简单例子：Hello World 创建项目目录和项目代码 构建项目的配置文件 设置 SBT 版本 简单例子：Hello World 创建项目目录和项目代码 一个合法的 sbt 项目可以在一个项目目录中包含单个文件。尝试创建一个包含hw.scala 文件的目录hello, 文件中的内容如下： object Hi { d... -
Overview
Table API & SQL Dependency Structure Table Program Dependencies Extension Dependencies Where to go next? Table API & SQL Apache Flink features two relational APIs - the Tab...