喜欢一个人就去追，因为在这一辈子里面，你可能只有这一次机会能牵到那个人的手了。有梦想就去努力，因为在这一辈子里面，现在不去勇敢地努力，也许就再也没有机会了。
IP属地：天津
-
java的定时器ScheduledThreadPoolExecutor一般来说java 常用的定时器由timer和ScheduledThreadPoolExecutor 但是timer是单线程操作，而且适用于简单的定时任务，ScheduledT...
-
-
flink sql(word count)如下图： 代码： import org.apache.flink.table.api.Table import org.apache.flink.table.api.scal...
-
flink sql(pojo对象)如下就是代码： object FlinkSQLPOJO { def main(args: Array[String]):Unit = { import org.apache....
-
flink table (pojo对象)如图： object Stream2Table4Bean { def main(args: Array[String]):Unit = { import org.apache...
-
flink table (word count)object Stream2Table { def main(args: Array[String]):Unit = { import org.apache.flink.st...
-
这个年纪了，你害怕自己会永远单身下去嘛？
前两天我看一个文章，里面说到这句话，当我读到这的时候，我当时也顿了一下，我有时候也怕，有时候也不怕。怕的是，总不能这么一个人一直下去吧，快乐也好，不开心也罢，也需要...
-
最容易取代的其实也最难取代
我听过很多故事，见过很多的悲欢离合。这里面不乏一些悲伤的结局。其实说到悲伤，也不尽然，每个人的看法都不一样，可能你觉得这个结局是意外的，也可能当事人觉得这个结果是正常的...
-
mysql的主从复制1.首先在两台机器安装MySQL 2.我选择两个虚拟机安装MySQL 192.168.172.41 作为master 192.168.172.42 作为slave 3.修改m...
-
sqoop加密脚本完成数据导入（rds=>hive）1.首先保证hdfs启动，执行如下命令 hadoop credential create my_db_password_alias -provider localjceks:...
-
-
Spark structured streaming(未完)Spark Structured Streaming 结构化流是基于Spark SQL引擎构建的可伸缩且容错的流处理引擎。您可以像对静态数据进行批处理计算一样来表示流计算。当...
-
zookeeper选举机制&写数据流程zookeeper选举是基于半数机制，只有集群中半数以上机器存活，那么集群就可用。 一般都按安装再奇数台机器。 zookeeper在配置文件并没有指定master和slave...
-
zookeeper动态监听服务器上下线1.服务器启动，会向zookeeper集群注册临时节点 2.客户端获取当前在线服务器的列表，并监听 3.如果某一台服务器下线，zookeeper会感知机器下线 4.临时节点删...
-
Spark Streaming 之check point小文件处理
我们都知道，spark streaming，采用有状态计算，需要设置check point目录。但是检查点文件都是小文件， 也会占用一些资源，所以这些检查点小文件，我们采用合...
-
zookeeper可视化zkui安装部署首先电脑配置jdk和maven: 下载对应压缩包：https://github.com/DeemOpen/zkui 在本地目录解压： 进入解压完的目录，运行cmd命令，打开控...