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

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

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

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

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

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

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

描述 对同一个窗口中的同个key所有数据进行自定义聚合 输入 WindwedStream 输出 DataStream 用法

描述 对一个窗口中的同个key的所有数据进行批量处理 context.window提供了对窗口属性的访问，如context.window.get...