-
Function
always comparator compose construct curry useWith flip groupBy identity invoker nAry once pipe tap always a → (* → a) Parameters valThe value to wrap in a func... -
2. Auxiliary SQL Functions for Spark SQL
Auxiliary SQL Functions for Spark SQL Auxiliary SQL Functions for Spark SQL Kyuubi provides several auxiliary SQL functions as supplement to Spark’s Built-in Functions ... -
Utility
_.attempt(func) Arguments Returns Example .callback([func=.identity], [thisArg]) Aliases Arguments Returns Example _.constant(value) Arguments Returns Example _.identi... -
变量管理
背景介绍 创建变量 在Flink SQL中引用变量 在Flink JAR作业的args中引用变量 背景介绍 在实际生产环境中，Flink作业一般很复杂，会依赖多个外部组件，例如，从Kafka中消费数据时要从HBase或Redis中去获取相关数据，然后将关联好的数据写入到外部组件，这样的情况下会导致如下问题： Flink作业想要关联这些组件，需... -
Relation
countBy difference differenceWith unionWith union gt gte intersection lt lte max min propEq sortBy pathEq maxBy minBy equals identical eqBy clamp sortWith inn... -
Issue Codes
Issue 1000 Issue 1001 Issue 1002 Issue 1003 Issue 1004 Issue 1005 Issue 1006 Issue 1007 Issue 1008 Issue 1009 Issue 1010 Issue 1011 Issue 1012 Issue 1013 Issue 1014 ... -
HdfsFile
Support Those Engines Key Features Description Supported DataSource Info Sink Options Tips Task Example Simple: For orc file format simple config For text file format with ... -
Rollback Mechanism
Handling partially failed commits Rolling back partially failed commits for a single writer Rolling back of partially failed commits w/ multi-writers Heartbeats Related Resourc... -
Hudi
Support Those Engines Key Features Description Supported DataSource Info Data Type Mapping Source Options Task Example Simple: Changelog 2.2.0-beta 2022-09-26 Hudi sour... -
Feishu
Support Those Engines Key Features Description Data Type Mapping Sink Options Task Example Simple: Changelog 2.2.0-beta 2022-09-26 Feishu sink connector Support Thos...