2a6f388eed9c

求這個一站式輔助功能解決工具柴墩，感謝感謝Ｗ钆馈！

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

hi大家好汪疮。新年又來了丹弱，微信群里又是各種紅包橫飛。作為技術(shù)人員的我們卻大可不必擔(dān)心一不小心铲咨，手速慢了點躲胳，又錯過了幾十萬。我們可以通過安卓的輔助功能來實現(xiàn)自己的微信自動搶紅包纤勒，...

thiagooo0

19922 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ù)更新水印捐康，應(yīng)該flush所有channel上的watermark，
// 意味著我們設(shè)置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導(dǎo)入功能, 其中 需要對已導(dǎo)入條目的做“更新” 未導(dǎo)入的條目做“新增” 其余的做“刪除” 細品需求 無非是對excel的數(shù)據(jù)和數(shù)據(jù)...

碼哥說

6779 1 5

2a6f388eed9c

簡書吃相?

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

來源|媽媽網(wǎng)育兒（ID：mmwyuer） 27歲離過婚的女人行冰，和35歲沒結(jié)過婚的女人，你愿意娶誰伶丐？ 有人做過一期街頭采訪悼做，很多男士的回答，看得我三觀震碎哗魂。 有男士說肛走，當然要選...

S小姐說

30172 90 455

2a6f388eed9c

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

java中使用SparkLauncher提交spark應(yīng)用

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

alexlee666

8081 2 1