FlinkSQL提供了连接外部数据的方法，即通过建立Flink表与外部数据关联起来。其中最基本的连接方式为普通动态表连接，普通动态表允许读取外部...

概念 自定义标量函数，接收一个或多个列，输出一个列，行与行是一一对应的 构造函数在jobmanager上创建udf时就执行 open方法在所有并...

依赖 描述 flinksql以多线程的方式将数据写入外部数据表 flinksql sink table的ddl中若声明了主键，则上游数据到达si...

谓词 谓词指的是带有过滤属性的系统关键词，如where、on、having、like、>等。 谓词下推 谓词下推表达的是让过滤提前执行，减少后续...

描述 通过operation信息(insert、update、delete)，实现了对上游数据的变更识别能力，这些信息会记录在于上游数据连接的f...

描述 自定义udf，接收一个字段的每一个value，对应输出转换后的新value，与原value的关系是一对一 依赖 示例 部署

描述 异步读取外部数据源，并使用这些外部数据对主流数据进行必要的转换 要求外部数据源支持异步读取 要求代码中的client支持发起异步请求 输入...

hive-exec-shaded 此包是hive exec的shaded版本，在flink环境访问hive需要用到此包，兼容flink，排除掉了...

描述 数据在KeyBy后对key按hash结果进入对应的KeyedProcessFunction subtask 同个key的数据的所有数据都会...