1. 학습
    2. /
  2. 강의
    3. /
  3. Scaling and Optimizing Data Pipelines with Polars
Connected

연습 문제

Multiplexing Parquet sinks

The team now needs two extracts from the same cleaned query: one for digital checkouts and one for physical. Build both writes lazily so Polars can plan the shared scan once, then run them together in one pass.

clean_checkouts is preloaded, along with DIGITAL_EXPORT_PATH and PHYSICAL_EXPORT_PATH.

지침

100 XP
  • Build both sinks lazily so they don't execute immediately.
  • Run both sinks together on the streaming engine.