馬老師drools規(guī)則引擎
2022-11-16 21:14 作者:janet19961217 | 我要投稿
?Materialized<String, List<String>, WindowStore<Bytes, byte[]>> storeMaterialized = Materialized.<String, List<String>, WindowStore<Bytes, byte[]>>as(
? ? ? ? ? ?"time-windowed-aggregated-stream-store").withKeySerde(stringSerde).withValueSerde(jsonSerde)
? ? ? ?.withRetention(Duration.ofMinutes(5));
?
標(biāo)簽：
