New game
Download
Get Academic Plan
Share game
Integrate it into your platform

You can integrate the game into an LMS compatible with LTI 1.1 or LTI 1.3 such as Canvas, Moodle, or Blackboard. This way, the scores will be automatically saved into the platform’s gradebook.
Download
You have exceeded the maximum number of games you can integrate into Google Classroom with your current Plan.

To integrate as many games as you want in Google Classroom, you need an Academic Plan or a Commercial Plan.

You have exceeded the maximum number of games you can integrate into Microsoft Teams with your current Plan.

To integrate as many games as you want in Microsoft Teams, you need an Academic Plan or a Commercial Plan.

Downloading games is an exclusive feature for users with an Academic Plan or a Commercial Plan.

Get your Academic Plan or your Commercial Plan now and start integrating your games into your LMS, website or blog.

If you wish, you can download a demo game here and test its integration:

SPARK - LRBA 4

Quiz

Played 20 %Accuracy 90 Average time 06:16

About this activity

Spark Streaming - Procesamiento de Datos en Tiempo Real

Created by

Mexico

Download the paper version to play

Make your own free game from our game creator
Compete against your friends to see who gets the best score in this game

Top Games

%
Anonymous
Anonymous
%
%
%
You have exceeded the maximum number of games you can print with your current Plan.

To print as many games as you want, you need an Academic Plan or a Commercial Plan.

Print your game
SPARK - LRBA 4
 

SPARK - LRBA 4Online version

Spark Streaming - Procesamiento de Datos en Tiempo Real

by HR Mexico
1

¿Cuál es la unidad básica de procesamiento en Spark Streaming DStream?

2

¿Qué garantiza exactly-once semantics en Structured Streaming?

3

En Kafka Direct Stream, ¿cómo se evitan receivers?

4

¿Qué maneja el watermark en Structured Streaming?

5

¿Cuál es el rol de StreamingContext?

6

En updateStateByKey, ¿qué usa StateSpec?

7

¿Qué habilita backpressure?

8

En windowed reduceByKeyAndWindow, parámetros son:

9

¿Output mode para agregaciones full table?

10

¿Checkpoint almacena qué?

11

En Structured Streaming, ¿qué es foreachBatch?

12

¿Mejor práctica para escalabilidad Kafka?

13

¿Qué mide scheduling delay?

14

En fault-tolerance receiver, ¿qué es WAL?

15

¿Trigger para baja latencia experimental?

16

¿Para data late en joins stream-stream?

17

¿Config para max rate Kafka partition?

18

En caso fraude, ¿por qué watermark?

19

¿Diferencia key DStream vs Structured?

20

¿Buena práctica idempotencia?

Explicación

DStreams procesan datos en micro-lotes como RDDs por batch interval.

WAL persiste offsets/transacciones; idempotencia evita duplicados.

Direct API lee offsets directamente de Kafka topics __consumer_offsets.

Define cutoff para procesar/drop late data en agregaciones.

Inicializa context con batch duration; único por app.

StateSpec define función update y spec para storage/timeout.

Ajusta input rate dinámicamente basado en processing delay.

windowDuration para tamaño, slide para overlap (e.g., 30s/10s).

Complete emite toda tabla actualizada por trigger.

Permite recovery completo desde último batch completado.

Aplica función a cada micro-lote output DataFrame.

Tasks paralelos match Kafka partitions para throughput.

Indicador backpressure; alto delay sugiere overload.

Replica datos a checkpoint antes ACK fuente.

Spark 3.0+ modo continuo sub-second (microbatch no).

Watermarks permiten joins con bounds temporales.

Limita input per partition en backpressure mode.

Evita estado infinito; drop data post-threshold.

Structured unifica con Spark SQL, mejor optimización.

Commit offsets solo tras sink exitoso para replay-safe.

Are you sure you want to leave the page?

If you leave the page, you will lose your game progress.