Pragmatische Methode zur Trennung von KeyedProcessfunction -Geschäftslogik in Flink
Posted: 15 May 2025, 18:49
Ich hoffe, das ist nicht allzu aus dem Spielraum für Stackoverflow. Wie man sich für ein komplexes System vorstellen würde, suche ich nach Möglichkeiten, die Geschäftslogik aufzuteilen. Der größte Teil der Geschäftslogik erfordert jedoch einen Kontext , Collector , Valuestate usw., die alle kündigten.
Ist dies die kanonische Flink Weg, um die Keyed -Business -Logik aufzuteilen?>
Code: Select all
private static void closeSession(
@NonNull final ValueState session,
@NonNull final ValueState snapshotHistory,
@NonNull final MapState scheduledActions,
@NonNull final OnTimerContext context) throws Exception {
log.info("{} Closing session", Instant.now());
// do stuff
}