一、创建语句
(1)创建数据库
1.检查系统中是否存在这个数据库,存在则删除
格式:
if exists(select * from sysdatabases where name数据库名)
drop database 数据库名
go例子:
if exists(select * from sysdataba…
1.前言
在我们使用Flink DataStream API编写业务代码时,aggregate()算子和AggregateFunction无疑是非常常用的。编写一个AggregateFunction需要实现4个方法:
/** Licensed to the Apache Software Foundation (ASF) under one* or more contributor li…