strømprosesseringsrammeverk
Et strømprosesseringsrammeverk er et programvareverktøy for kontinuerlig, sanntidsbehandling av datastrømmer. Slike rammeverk lar applikasjoner prosessere hendelser mens de ankommer, ofte med støtte for tidsbasert vinduesbehandling, tilstandshåndtering og innebygd feiltoleranse.
Hovedtrekkene inkluderer sanntidsbehandling av hendelser, støtte for eventtid og vinduer (f.eks. tidsvinduer som tumlende, glidende eller
Arkitekturen består vanligvis av kilder (data innganger), en distribuert prosesseringsmotor, tilstands- eller lagringslagre og synker (utganger).
Tilløp til ulike programmeringsmodeller inkluderer dataflytbasert programmering og teknikker basert på små batcher eller helt sanntidsflyt.
Eksempler på kjente strømprosesseringsrammeverk er Apache Flink, Apache Spark Structured Streaming, Apache Kafka Streams og Google
Utfordringer inkluderer kompleksiteten med å sikre stadig riktig semantikk (for eksempel exactly-once), håndtering av store tilstandssett,