Pragmatische Methode zur Trennung von KeyedProcessfunction -Geschäftslogik in Flink ⇐ Java

[Anonymous]

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.

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
}

Ist dies die kanonische Flink Weg, um die Keyed -Business -Logik aufzuteilen?>