Ultimate access to all questions.
Upgrade Now 🚀
Sign in to unlock AI tutor
What strategy can be employed to enhance the performance of a Dataflow pipeline that processes compressed gzip text files, utilizes SideInputs for data joining, and directs errors to a dead-letter queue?
A
Introduce a retry mechanism for records that face errors
B
Opt for compressed Avro files over gzip
C
Reduce the batch size utilized in the pipeline
D
Substitute the SideInput with CoGroupByKey to boost efficiency
