package com.sjw.flink import org.apache.flink.api.common.typeinfo.BasicTypeInfoimport org.apache.flink.api.java.io.jdbc.JDBCInputFormatimport org.apac ...
分类：
数据库 时间：
2020-07-10 00:07:12
阅读次数：
121
package com.sjw.flink import org.apache.flink.api.scala._ object WordCount { def main(args: Array[String]): Unit = { //创建批处理执行环境 val env: ExecutionEnv ...
分类：
其他好文 时间：
2020-07-10 00:05:16
阅读次数：
84
package com.sjw.hbase; import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.*;import org.apache.hadoop.hbase.client.*;import org ...
package com.sjw.flink import java.sql.{Connection, DriverManager, PreparedStatement} import org.apache.flink.configuration.Configurationimport org.apa ...
分类：
数据库 时间：
2020-07-10 00:01:11
阅读次数：
81
package com.sjw.flink import org.apache.flink.streaming.api.scala._import org.apache.flink.streaming.api.windowing.time.Time object WindowTest { def m ...
分类：
其他好文 时间：
2020-07-09 23:59:55
阅读次数：
253
package com.sjw.flink.sql import org.apache.flink.api.scala._import org.apache.flink.table.api.{Table, TableEnvironment}import org.apache.flink.types. ...
分类：
数据库 时间：
2020-07-09 23:55:33
阅读次数：
145
Playbook简介 playbook是由一个或多个模块组成得，使用多个不同得模块， 完成一件事情 playbook通过yaml语法识别描述得状态文件，扩展名是yaml。 yaml 三板斧 缩进：yaml使用一个固定的缩进风格表示层级结构，每个缩进由两个空格组成，不能使用tabs（默认，因为一个ta ...
分类：
Web程序 时间：
2020-07-09 22:30:32
阅读次数：
97
mysql 添加字段 ALTER TABLE t_user ADD COLUMN user_age int(11) DEFAULT NULL COMMENT '年龄' AFTER user_email; mysql 修改字段 ALTER TABLE user10 MODIFY email VARCH ...
分类：
数据库 时间：
2020-07-09 15:27:30
阅读次数：
388
1> 创建测试资源 1.命令获取deployment yaml模板 kubectl create deployment web --image=nginx:1.14 -o yaml --dry-run >deploy-web.yaml 修改deployment -web模板，添加pod限制 apiV ...
分类：
其他好文 时间：
2020-07-09 15:08:42
阅读次数：
159
承接上一篇，NoSQL实验 MapReduce实验 如何在Eclipse中运行MapReduce程序，参考厦大数据库实验室博客 总体代码： package org.apache.hadoop.examples; import java.io.IOException; import java.util ...
分类：
其他好文 时间：
2020-07-09 15:08:03
阅读次数：
127
