Spark SQL, DataFrames and Datasets Guide SQL Datasets and DataFrames Spark SQL, DataFrames and Datasets Guide Spark SQL is a Spark module for structured data processing. Unlik...

DataStream API Integration Converting between DataStream and Table Dependencies and Imports Configuration Execution Behavior Handling of (Insert-Only) Streams Examples for from...

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

ALTER Statements Run an ALTER statement ALTER TABLE ALTER VIEW ALTER DATABASE ALTER FUNCTION ALTER Statements ALTER statements are used to modified a registered table/view/...

算子 数据流转换 Map DataStream → DataStream FlatMap DataStream → DataStream Filter DataStream → DataStream KeyBy DataStream → KeyedStream Reduce KeyedStream → DataStream Window ...

算子 数据流转换 Map DataStream → DataStream FlatMap DataStream → DataStream Filter DataStream → DataStream KeyBy DataStream → KeyedStream Reduce KeyedStream → DataStream Window ...

Project Configuration Flink Core and Application Dependencies Setting up a Project: Basic Dependencies Adding Connector and Library Dependencies Scala Versions Hadoop Dependenc...

算子 数据流转换 Map DataStream → DataStream FlatMap DataStream → DataStream Filter DataStream → DataStream KeyBy DataStream → KeyedStream Reduce KeyedStream → DataStream Window ...

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

How to structure a .sbt build to cross-compile with Scala and Scala.js? Can I use macros with Scala.js? What about compiler plugins? Where can I find an example of non trivial Sc...