求這個(gè)一站式輔助功能解決工具，感謝感謝??！
Android：輔助功能之自動(dòng)搶紅包hi大家好。新年又來(lái)了，微信群里又是各種紅包橫飛。作為技術(shù)人員的我們卻大可不必?fù)?dān)心一不小心，手速慢了點(diǎn)，又錯(cuò)過(guò)了幾十萬(wàn)。我們可以通過(guò)安卓的輔助功能來(lái)實(shí)現(xiàn)自己的微信自動(dòng)搶紅包，...
```
public class OneInputStreamTask<IN, OUT> extends StreamTask<OUT, OneInputStreamOperator<IN, OUT>> {
@Nullable private CheckpointBarrierHandler checkpointBarrierHandler;
private final WatermarkGauge inputWatermarkGauge = new WatermarkGauge();
```
大概是在這里吧，OneInputStreamTask代表一個(gè)階段，初始化了一個(gè)final WatermarkGauge，每個(gè)階段共享一個(gè)WatermarkGauge對(duì)象，刷新了volatile currentWatermark，各個(gè)線程里的channel立馬就拿到了最新的的值。就達(dá)到了`flush所有channel上的watermark`的目的。
watermark原理之watermark的下發(fā)watermark 如何下發(fā)的? 一、 數(shù)據(jù)讀取 A. AbstractStreamTaskNetworkInput：該類(lèi)是用于讀取上游數(shù)據(jù) 對(duì)象類(lèi)別 含義：StreamS...
```
@Override
public void emitWatermark(Watermark watermark) throws Exception {
// flush水印
watermarkGauge.setCurrentWatermark(watermark.getTimestamp());
// 下發(fā)水印
operator.processWatermark(watermark);
}
```
```
private volatile long currentWatermark = 1657898217001L;
public void setCurrentWatermark(long watermark) {
currentWatermark = watermark;
}
```
flush 水印即是更新這里的currentWatermark,它是volatile,各線程立馬可見(jiàn)。這里是在做UI統(tǒng)計(jì)的時(shí)候會(huì)調(diào)用到，但是該phase的各channel是怎么刷新的，說(shuō)實(shí)話，還是不太明白，但它確實(shí)做到了。
watermark原理之watermark的下發(fā)watermark 如何下發(fā)的? 一、 數(shù)據(jù)讀取 A. AbstractStreamTaskNetworkInput：該類(lèi)是用于讀取上游數(shù)據(jù) 對(duì)象類(lèi)別 含義：StreamS...
watermark 如何下發(fā)的? 一、 數(shù)據(jù)讀取 A. AbstractStreamTaskNetworkInput：該類(lèi)是用于讀取上游數(shù)據(jù) 對(duì)象類(lèi)別 含義：StreamS...
```
// 因?yàn)楫?dāng)前所有channel空閑，并且channel都無(wú)法繼續(xù)更新水印，應(yīng)該flush所有channel上的watermark，
// 意味著我們?cè)O(shè)置channel 中最大的watermark作為新水印
// 因?yàn)樵谄渌優(yōu)閕dle的時(shí)候仍然會(huì)下發(fā)min watermark，所以只需要在最后一個(gè)channel變成idle且等于上次min watermark的時(shí)候flush
if (channelStatuses[channelIndex].watermark == lastOutputWatermark) {
findAndOutputMaxWatermarkAcrossAllChannels(output);
}
```
寫(xiě)得很好。但對(duì)于這段代碼，只看到當(dāng)所有通道都空閑后，取最大水印下發(fā)，但并沒(méi)有看到對(duì)當(dāng)前所有通道進(jìn)行flush的動(dòng)作。
watermark原理之watermark的下發(fā)watermark 如何下發(fā)的? 一、 數(shù)據(jù)讀取 A. AbstractStreamTaskNetworkInput：該類(lèi)是用于讀取上游數(shù)據(jù) 對(duì)象類(lèi)別 含義：StreamS...
private List<People> sameList(List<People> oldArrayList, List<People> newArrayList) {
List<People> resultList = newArrayList.stream()
.filter(item -> oldArrayList.stream().map(e -> e.getCode())
.collect(Collectors.toList()).contains(item.getCode()))
.collect(Collectors.toList());
return resultList;
}
大哥，你這兩個(gè)list如果都是上千的數(shù)據(jù)，一下就是幾百萬(wàn)次循環(huán)，得把
oldArrayList.stream().map(e -> e.getCode())
.collect(Collectors.toList())
單獨(dú)拿出來(lái)
兩個(gè)對(duì)象List根據(jù)屬性取交集和差集背景介紹 咸魚(yú)君最近做了個(gè)需求, excel導(dǎo)入功能, 其中 需要對(duì)已導(dǎo)入條目的做“更新” 未導(dǎo)入的條目做“新增” 其余的做“刪除” 細(xì)品需求 無(wú)非是對(duì)excel的數(shù)據(jù)和數(shù)據(jù)...
簡(jiǎn)書(shū)吃相?
“27歲離過(guò)婚和35歲未婚的女人，你會(huì)娶誰(shuí)？”這個(gè)男人的回答惹怒整個(gè)朋友圈來(lái)源|媽媽網(wǎng)育兒（ID：mmwyuer） 27歲離過(guò)婚的女人，和35歲沒(méi)結(jié)過(guò)婚的女人，你愿意娶誰(shuí)？ 有人做過(guò)一期街頭采訪，很多男士的回答，看得我三觀震碎。 有男士說(shuō)，當(dāng)然要選...
你哪個(gè)版本啊
launcher.setConf(SparkLauncher.EXECUTOR_CORES, 16);
這樣寫(xiě)不會(huì)報(bào)錯(cuò)嗎
java中使用SparkLauncher提交spark應(yīng)用將開(kāi)發(fā)好的spark application（對(duì)于java/scala來(lái)說(shuō)是jar）提交到spark集群執(zhí)行的方式通常包括兩種，一種是通常使用的spark submit腳本（...
