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
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
Table API是流处理和批处理通用的关系型API，Table API可以基于流输入或者批输入来运行而不需要进行任何修改。Table API是SQL语言的超集并专门为Apache Flink设计的，Table API是Scala 和Java语言集成式的API。与常规SQL语言中将查询指定为字符串不 ...
分类：
数据库 时间：
2020-07-09 15:03:48
阅读次数：
83
1、初识Flink Apache Flink是一个框架和分布式处理引擎，用于对无界和有界数据流进行有状态计算。Flink被设计在所有常见的集群环境中运行，以内存执行速度和任意规模来执行计算。 Flink起源于Stratosphere项目，Stratosphere是在2010~2014年由3所地处柏林 ...
分类：
其他好文 时间：
2020-07-09 13:49:53
阅读次数：
59
