2a6f388eed9c

求這個一站式輔助功能解決工具抬纸，感謝感謝＠趾帷！

Android：輔助功能之自動搶紅包

hi大家好硫麻。新年又來了，微信群里又是各種紅包橫飛。作為技術人員的我們卻大可不必擔心一不小心，手速慢了點睛藻，又錯過了幾十萬。我們可以通過安卓的輔助功能來實現(xiàn)自己的微信自動搶紅包邢隧，...

thiagooo0

19923 8 45

2a6f388eed9c

```
public class OneInputStreamTask<IN, OUT> extends StreamTask<OUT, OneInputStreamOperator<IN, OUT>> {

@Nullable private CheckpointBarrierHandler checkpointBarrierHandler;

private final WatermarkGauge inputWatermarkGauge = new WatermarkGauge();
```
大概是在這里吧修档，OneInputStreamTask代表一個階段，初始化了一個final WatermarkGauge府框，每個階段共享一個WatermarkGauge對象，刷新了volatile currentWatermark讥邻，各個線程里的channel立馬就拿到了最新的的值迫靖。就達到了`flush所有channel上的watermark`的目的。

watermark原理之watermark的下發(fā)

watermark 如何下發(fā)的? 一兴使、 數(shù)據(jù)讀取 A. AbstractStreamTaskNetworkInput：該類是用于讀取上游數(shù)據(jù) 對象類別 含義：StreamS...

ZYvette

753 4 1

2a6f388eed9c

```
@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,各線程立馬可見系宜。這里是在做UI統(tǒng)計的時候會調(diào)用到，但是該phase的各channel是怎么刷新的发魄，說實話盹牧，還是不太明白，但它確實做到了励幼。

watermark原理之watermark的下發(fā)

watermark 如何下發(fā)的? 一汰寓、 數(shù)據(jù)讀取 A. AbstractStreamTaskNetworkInput：該類是用于讀取上游數(shù)據(jù) 對象類別 含義：StreamS...

ZYvette

753 4 1

2a6f388eed9c

```
// 因為當前所有channel空閑，并且channel都無法繼續(xù)更新水印嵌削，應該flush所有channel上的watermark毛好，
// 意味著我們設置channel 中最大的watermark作為新水印
// 因為在其他變?yōu)閕dle的時候仍然會下發(fā)min watermark，所以只需要在最后一個channel變成idle且等于上次min watermark的時候flush
if (channelStatuses[channelIndex].watermark == lastOutputWatermark) {
findAndOutputMaxWatermarkAcrossAllChannels(output);
}
```
寫得很好苛秕。但對于這段代碼肌访，只看到當所有通道都空閑后，取最大水印下發(fā)艇劫，但并沒有看到對當前所有通道進行flush的動作吼驶。

watermark原理之watermark的下發(fā)

watermark 如何下發(fā)的? 一、 數(shù)據(jù)讀取 A. AbstractStreamTaskNetworkInput：該類是用于讀取上游數(shù)據(jù) 對象類別 含義：StreamS...

ZYvette

753 4 1

2a6f388eed9c

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;
}

大哥，你這兩個list如果都是上千的數(shù)據(jù)旨剥，一下就是幾百萬次循環(huán)咧欣，得把
oldArrayList.stream().map(e -> e.getCode())
.collect(Collectors.toList())
單獨拿出來

兩個對象List根據(jù)屬性取交集和差集

背景介紹 咸魚君最近做了個需求, excel導入功能, 其中 需要對已導入條目的做“更新” 未導入的條目做“新增” 其余的做“刪除” 細品需求 無非是對excel的數(shù)據(jù)和數(shù)據(jù)...

碼哥說

6780 1 5

2a6f388eed9c

簡書吃相?

“27歲離過婚和35歲未婚的女人，你會娶誰轨帜？”這個男人的回答惹怒整個朋友圈

來源|媽媽網(wǎng)育兒（ID：mmwyuer） 27歲離過婚的女人魄咕，和35歲沒結過婚的女人，你愿意娶誰蚌父？ 有人做過一期街頭采訪哮兰，很多男士的回答，看得我三觀震碎苟弛。 有男士說喝滞，當然要選...

S小姐說

30172 90 455

2a6f388eed9c

你哪個版本啊
launcher.setConf(SparkLauncher.EXECUTOR_CORES, 16);
這樣寫不會報錯嗎

java中使用SparkLauncher提交spark應用

將開發(fā)好的spark application（對于java/scala來說是jar）提交到spark集群執(zhí)行的方式通常包括兩種，一種是通常使用的spark submit腳本（...

alexlee666

8081 2 1