Home › GCP Data Engineer › cloudcomputing › gcpdeprocess › Which Apache Beam concept handles events arrivin…
Which Apache Beam concept handles events arriving AFTER their window closes — letting the Data Engineer specify how to combine them with already-emitted results (PDE §2.2)?
ALate-data handling via triggers + allowed-lateness on a windowing strategy
BCloud DNS
CDisabling streaming entirely
DDropping every late event unconditionally without explicit allowed-lateness
Answer & Solution
Correct answer: A. Late-data handling via triggers + allowed-lateness on a windowing strategy
Beam triggers + allowed lateness manage late data (per PDE §2.2 late arrival). The other options don't fit Beam's late-data model.
Related questions
Which Dataflow feature lets a Data Engineer reuse a published pipeline as a parameterised,Which Dataproc feature should a Data Engineer use to run a Spark job ONLY when work existsWhich Dataflow feature should a Data Engineer enable to BACKFILL or REPROCESS late-arrivinWhich GCP service lets a Data Engineer write streaming SQL queries directly against a Pub/Which Pub/Sub delivery model should a Data Engineer use when subscribers should pull messaWhich BigQuery feature lets a Data Engineer run ANALYTICAL QUERIES across data still livinWhich GCP service should a Data Engineer use for lightweight, serverless workflow orchestrWhich GCP service should a Data Engineer use to orchestrate Cloud Dataflow / BigQuery / Da