flinksql中怎么自定义udf

  介绍

这期内容当中小编将会给大家带来有关flinksql中怎么自定义udf,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。

1, pom.xml(注意:pom中有多余的jar,本人暂时未进行剔除)

 & lt; ? xml  version=?.0“,编码=癠TF-8" ?比;
  http://maven.apache.org/POM/4.0.0" & lt; project  xmlns=?;
  ,,,,,,,,xmlns: xsi=癶ttp://www.w3.org/2001/XMLSchema-instance"
  ,,,,,,,,xsi: schemaLocation=? http://maven.apache.org/POM/4.0.0 , http://maven.apache.org/xsd/maven-4.0.0.xsd"比;
  ,,,& lt; modelVersion> 4.0.0
  
  ,,,& lt; groupId> org.example
  ,,,& lt; artifactId> udf
  ,,,& lt; version> 1.0 -snapshot
  
  ,,,& lt; properties>
  ,,,,,,,& lt; maven.compiler.source> 8 & lt;/maven.compiler.source>
  ,,,,,,,& lt; maven.compiler.target> 8 & lt;/maven.compiler.target>
  ,,,& lt;/properties>
  
  ,,,& lt; dependencies>
  
  ,,,,,,,& lt; !——,要么……,——比;
  ,,,,,,,& lt; dependency>
  ,,,,,,,,,,,& lt; groupId> org.apache.flink
  ,,,,,,,,,,,& lt; artifactId> flink-table-api-java-bridge_2.11
  ,,,,,,,,,,,& lt; version> 1.10.2
  ,,,,,,,,,,,& lt; scope> provided
  ,,,,,,,& lt;/dependency>
  ,,,,,,,& lt; !——,还是…,——比;
  ,,,,,,,& lt; dependency>
  ,,,,,,,,,,,& lt; groupId> org.apache.flink
  ,,,,,,,,,,,& lt; artifactId> flink-table-api-scala-bridge_2.11
  ,,,,,,,,,,,& lt; version> 1.10.2
  ,,,,,,,,,,,& lt; scope> provided
  ,,,,,,,& lt;/dependency>
  ,,,,,,,& lt; !——,要么……,(for 从而old  planner  that  was  available  before  Flink  1.9),——比;
  ,,,,,,,& lt; dependency>
  ,,,,,,,,,,,& lt; groupId> org.apache.flink
  ,,,,,,,,,,,& lt; artifactId> flink-table-planner_2.11
  ,,,,,,,,,,,& lt; version> 1.10.2
  ,,,,,,,,,,,& lt; scope> provided
  ,,,,,,,& lt;/dependency>
  ,,,,,,,& lt; !——,或…,(for 从而new  Blink 规划师),——比;
  ,,,,,,,& lt; dependency>
  ,,,,,,,,,,,& lt; groupId> org.apache.flink
  ,,,,,,,,,,,& lt; artifactId> flink-table-planner-blink_2.11
  ,,,,,,,,,,,& lt; version> 1.10.2
  ,,,,,,,,,,,& lt; scope> provided
  ,,,,,,,& lt;/dependency>
  ,,,,,,,& lt; dependency>
  ,,,,,,,,,,,& lt; groupId> org.apache.flink
  ,,,,,,,,,,,& lt; artifactId> flink-streaming-scala_2.11
  ,,,,,,,,,,,& lt; version> 1.10.2
  ,,,,,,,,,,,& lt; scope> provided
  ,,,,,,,& lt;/dependency>
  
  ,,,,,,,& lt; dependency>
  ,,,,,,,,,,,& lt; groupId> org.apache.flink
  null
  null
  null
  null
  null
  null
  null
  null
  null
  null
  null
  null
  null
  null
  null
  null

flinksql中怎么自定义udf