Özel bir yığın lavabosu kullanma
Polars'ın yerel olarak desteklemediği özel işlemler için kendi fonksiyonunu geçebilirsin. Ekip, normalde yerleşik bir lavaboyu kullanacak olsa da bu deseni görmek istiyor. digital_rows verisini önceden tanımlı record_batch fonksiyonundan akıt.
digital_rows önceden yüklendi. Her yığının satır sayısını ve checkout toplamını batch_summaries içine kaydeden record_batch(batch) fonksiyonu da senin için tanımlı.
Bu egzersiz, kursun bir parçasıdır
Polars ile Veri Hatlarını Ölçeklendirme ve Optimize Etme
Egzersiz talimatları
- Streaming motorunda,
digital_rowsverisini fonksiyondan 5.000 satırlık yığınlar halinde akıt.
Uygulamalı etkileşimli egzersiz
Bu egzersizi bu örnek kodu tamamlayarak deneyin.
# Stream batches through the record_batch function
digital_rows.____(
record_batch,
____=5_000,
____="streaming",
)
result = pl.DataFrame(batch_summaries)
print(result)