1.自定义sink 在flink中，sink负责最终数据的输出。使用DataStream实例中的addSink方法，传入自定义的sink类 定义一个printSink()，使得其打印显示的是真正的task号（默认的情况是task的id+1） MyPrintSink package cn._51doi ...
分类：
其他好文 时间：
2020-06-16 23:19:16
阅读次数：
61
suse下设置IP的3种方法 https://blog.csdn.net/junmail/article/details/5429470?utm_medium=distribute.pc_relevant_t0.none-task-blog-BlogCommendFromMachineLearnPa ...
分类：
其他好文 时间：
2020-06-16 20:42:09
阅读次数：
89
往届学长的一场比赛. 总结：三道水题 haha！ Task 1 省选 jloi.cpp/in/out 给你一个字符串，你每次只能删除一个回文串，问你最少需要几步将字符串删完，或输出无解. 题解：显然，答案最多为 2，而如果这个串本身就不是回文串答案就是 1，所以难点就是判断无解的情况. 手画几组发现 ...
分类：
其他好文 时间：
2020-06-16 15:25:22
阅读次数：
48
前言 环境搭建好后，接下来就是操作手机上的应用app了，那么在写代码前要先获取到要操作app的包名package 和 activity ，好用到代码中； 一、获取参数值 下面呢，是两中获取的方式： 方法一： 使用命令> adb logcat 获取手机日志信息， 打开要操作的app后，Ctrl +c ...
分类：
移动开发 时间：
2020-06-16 12:59:46
阅读次数：
119
两种实现方式继承Thread类或者实现Runnable接口 使用实现Runnable接口和继承Thread类这两种开辟新线程的方法的选择应该优先选择实现Runnable接口这种方式去开辟一个新的线程。因为接口的实现可以实现多个，而类的继承只能是单继承。因此在开辟新线程时能够使用Runnable接口就 ...
分类：
编程语言 时间：
2020-06-16 10:23:10
阅读次数：
55
如果想在任务成功或者失败额外做点事，可以重写Task类。 tasks.py from __future__ import absolute_import, unicode_literals from .celery import app from celery.task import Task cl ...
分类：
其他好文 时间：
2020-06-16 00:47:15
阅读次数：
358
元数据更新过程？ MapReduce的Shuffle过程？ HDFS的读的流程？ HDFS写的流程？ 如何将hadoop配置文件从一台机器同步到另一台机器上？ scp -r hadoop-2.7.3 hpsk@192.168.134.222:/opt/modules/ 如何终止yarn上正在运行的程 ...
分类：
其他好文 时间：
2020-06-15 23:20:15
阅读次数：
144
Android Studio如何新建一个项目以及移除项目（从AS中移除但是文件还在本地） 一、新建一个项目 1、如果你是第一次使用这个软件 那么点击第一个“Start a new Android Studio project” 2、一般选择空白Activity 然后点击下一步 3、接着就是给你的项目 ...
分类：
移动开发 时间：
2020-06-15 23:07:22
阅读次数：
98
第1关：写一个函数 using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; namespace G1 { class Pro ...
https://blog.csdn.net/sisi_chen/article/details/82389773?utm_medium=distribute.pc_relevant.none-task-blog-BlogCommendFromMachineLearnPai2-2.nonecase&d ...
分类：
编程语言 时间：
2020-06-15 14:15:36
阅读次数：
244
