当前位置: 首页 > news >正文

用jsp做留言板网站北京seo优化排名

用jsp做留言板网站,北京seo优化排名,小程序制作怎么导入题库,自己做的网站别人当写入数据到外部数据库时,Flink 会使用 DDL 中定义的主键。如果定义了主键,则连接器将以 upsert 模式工作,否则连接器将以 append 模式工作 package cn.edu.tju.demo2;import org.apache.flink.streaming.api.environment.StreamExecutionE…

当写入数据到外部数据库时,Flink 会使用 DDL 中定义的主键。如果定义了主键,则连接器将以 upsert 模式工作,否则连接器将以 append 模式工作

package cn.edu.tju.demo2;import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.DataTypes;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableResult;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.table.descriptors.*;
import org.apache.flink.types.Row;public class Test41 {//demo 是MySQL中已经创建好的表//create table demo (userId varchar(50) not null,total bigint,avgVal double);private static String FILE_PATH = "info.txt";public static void main(String[] args) throws Exception {StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();env.setParallelism(1);StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);tableEnv.connect(new FileSystem().path(FILE_PATH)).withFormat(new Csv()).withSchema(new Schema().field("userId", DataTypes.VARCHAR(50)).field("ts", DataTypes.INT()).field("val", DataTypes.DOUBLE())).createTemporaryTable("input");Table dataTable = tableEnv.from("input");Table aggregateTable = dataTable.groupBy("userId").select("userId, userId.count as total, val.avg as avgVal");String sql="create table jdbcOutputTable (" +" userId varchar(50) not null,total bigint,avgVal double " +") with (" +" 'connector.type' = 'jdbc', " +" 'connector.url' = 'jdbc:mysql://xx.xx.xx.xx:3306/test', " +" 'connector.table' = 'demo', " +" 'connector.driver' = 'com.mysql.jdbc.Driver', " +" 'connector.username' = 'root', " +" 'connector.password' = 123456' )";tableEnv.sqlUpdate(sql);aggregateTable.insertInto("jdbcOutputTable");tableEnv.execute("my job");}
}

文件info.txt

user1,1680000890,31.6
user2,1681111900,38.3
user1,1680000890,34.9
http://www.hengruixuexiao.com/news/5256.html

相关文章:

  • 徐州社交网站电商网站搭建
  • 没有公司怎么做网站百度seo站长工具
  • wdcp wordpress https郑州seo教程
  • 做vip兼职设计师的网站有哪些广州网络营销公司
  • 建设项目信息查询seo zac
  • 手机移动网络屏蔽的网站正规手游代理平台有哪些
  • 企业网站建设排名西安百度推广排名
  • 麻涌企业网站建设百度seo排名软
  • 网站免费推广怎么做百度竞价排名软件
  • 网站收录 作用友情链接购买平台
  • 海口 网站开发做运营的具体做什么
  • 网站小logo设计黄页88推广多少钱一年
  • 陕西政务服务网注册公司流程搜索引擎优化核心
  • 深圳手机建网站做竞价推广大概多少钱
  • 郑州网站优化岳阳seo公司
  • 专业模板网站制作哪家好个人免费网站创建入口
  • 武汉做网站网络公司广州百度提升优化
  • 平面设计网站免费大推荐广州推广seo
  • 网站设置为应用程序网站设计的流程
  • 接收新网站如何做诊断免费建站网站
  • 网站建设佰首选金手指十八竞价广告是什么意思
  • 网站开发维护报价单今日国家新闻
  • 个人做搜索网站违法吗南京高端品牌网站建设
  • wordpress 100并发网站站外优化推广方式
  • 济南简单的网站制作十大互联网平台
  • 做网站如何自动采集图片上海seo外包公司
  • 胶州网站建设哪里有优化算法
  • 毕业做网站运营好吗上海aso
  • dede大气黑色网站源码百度关键词优化词精灵
  • 网站建设的英文翻译凡科建站官网登录