馬老師通過C語言深度解讀Redis核心架構(gòu)
Table<Windowed<String>, List<String>> kTable = kStream.groupBy((k, v) -> "defaultKey")
? ? ? ?.windowedBy(TimeWindows.of(windowSize).grace(Duration.ZERO))
? ? ? ?.aggregate(() -> new ArrayList<>(), (k, v, agg) -> {
? ? ? ? ?System.out.println("========== aggregate record ==========");
? ? ? ? ?log.info("k: {}, v: {}, agg: {}", k, v, agg);
? ? ? ? ?if (!signal.equals(v)) {
? ? ? ? ? ?agg.add(v);
標(biāo)簽：
