飛滴出行網(wǎng)約車項(xiàng)目2022版
2022-11-18 21:37 作者:janet19961217 | 我要投稿
? ?Duration windowSize = Duration.ofSeconds(10);
? ?Materialized<String, List<String>, WindowStore<Bytes, byte[]>> storeMaterialized = Materialized.<String, List<String>, WindowStore<Bytes, byte[]>>as(
? ? ? ? ? ?"").withKeySerde(stringSerde).withValueSerde(jsonSerde)
? ? ? ?.withRetention(Duration.ofMinutes(5));
? ?ConcurrentHashMap<String, Long> aggRecordMap = new ConcurrentHashMap<>();
? ?String lastMsgTimeKey = "lastMsgTimeKey";
? ?String signal = "signal";
標(biāo)簽：
