Unbounded Streaming Processing Concepts

Choose a study mode

Play Quiz
Study Flashcards
Spaced Repetition
Chat to Lesson

Podcast

Play an AI-generated podcast conversation about this lesson
Download our mobile app to listen on the go
Get App

Questions and Answers

Was ist das Ziel von Time Agnostic Processing?

  • Die genaue Zeitanalyse von Ereignissen
  • Die Verarbeitung von Ereignissen in Echtzeit
  • Die Verarbeitung von Ereignissen unabhängig von der Zeit (correct)
  • Die zeitliche Anordnung von Ereignissen in festgelegten Intervallen

Was geschieht beim Windowing by Processing Time?

  • Die Fenstergröße wird dynamisch an die Verarbeitungsgeschwindigkeit angepasst
  • Fenster werden basierend auf dem Zeitpunkt des Eintreffens der Daten erstellt
  • Daten werden in ein Fenster eingeteilt, basierend auf dem Zeitpunkt der Ereigniswahrnehmung im System (correct)
  • Die Daten werden in Fenster eingeteilt, basierend auf dem Zeitpunkt des tatsächlichen Eintreffens der Events

Welche Art von Zeitfenster kann beim Sliding Windowing auftreten?

  • Zeitfenster mit zeitlicher Ãœberlappung (correct)
  • Zeitfenster, die unabhängig voneinander sind
  • Zeitfenster ohne Ãœberlappung
  • Zeitfenster mit zufälliger Dauer

Was macht das Joining bei Stream-Daten?

<p>Kombiniert Daten von unterschiedlichen Streams anhand von Identifiern (C)</p> Signup and view all the answers

Was ist die Hauptfunktion von Event Sourcing?

<p>Speicherung der Historie durch Speicherung der Events, die zum Zustand geführt haben (D)</p> Signup and view all the answers

Welches Problem wird durch Event Sourcing gelöst?

<p>Ãœberschreibung von Werten, wodurch die Historie verloren geht (D)</p> Signup and view all the answers

Was ist die Funktion eines Snapshots im Zusammenhang mit Event Sourcing?

<p>Speichern des Domain Models an einem bestimmten Zeitpunkt zur Performanzoptimierung (D)</p> Signup and view all the answers

Warum werden alle Events in einem Event Store persistiert?

<p>Um die zeitliche Ordnung der Events sicherzustellen (A)</p> Signup and view all the answers

Was passiert, wenn der Coordinator den Zustand im Transaction Log zu „prepare commit“ ändert?

<p>Die Transaktion kann garantiert bestätigt werden (A)</p> Signup and view all the answers

Welche Markers werden gesetzt, wenn die Transaktion abgebrochen wurde?

<p>Abort Markers (B)</p> Signup and view all the answers

Was geschieht, nachdem der Coordinator die Commit Markers in Partitionen geschrieben hat?

<p>Die Transaktion kann nicht mehr abgebrochen werden (B)</p> Signup and view all the answers

Was müssen Consumer konfigurieren, um alle Nachrichten, einschließlich von offenen oder abgebrochenen Transaktionen, sichtbar zu machen?

<p>Isolation.level = read_uncommitted (C)</p> Signup and view all the answers

Was sind die Ziele der Ereignisverarbeitung?

<p>Verarbeitung massiver Datenströme und Datendurchsatz (A)</p> Signup and view all the answers

Welche Funktionen definieren die Application Services im Business Layer?

<p>Abstraktion eines Domain Models und High Level Business Funktionen (D)</p> Signup and view all the answers

Was ist der Hauptunterschied zwischen Commands und Queries im CQS?

<p>Queries haben keine Business Logik, während Commands Domänen Modelle unterstützen (A)</p> Signup and view all the answers

Was kennzeichnet das CQRS in Bezug auf Commands und Queries?

<p>Commands und Queries sind komplett isoliert (D)</p> Signup and view all the answers

Flashcards are hidden until you start studying

More Like This

Amazon Kinesis: Real-Time Data Processing
25 questions
Introduction to Spark Streaming
24 questions

Introduction to Spark Streaming

PersonalizedBlueTourmaline2204 avatar
PersonalizedBlueTourmaline2204
Structured Streaming in Spark
6 questions

Structured Streaming in Spark

UnequivocalNephrite9216 avatar
UnequivocalNephrite9216
Use Quizgecko on...
Browser
Browser