Ablakfüggvények az adatfolyam leképezésében

  • Cikk

A következőkre vonatkozik: Azure Data Factory Azure Synapse Analytics

Tipp.

Próbálja ki a Data Factoryt a Microsoft Fabricben, amely egy teljes körű elemzési megoldás a nagyvállalatok számára. A Microsoft Fabric az adattovábbítástól az adatelemzésig, a valós idejű elemzésig, az üzleti intelligenciáig és a jelentéskészítésig mindent lefed. Ismerje meg, hogyan indíthat új próbaverziót ingyenesen!

Az adatfolyamok az Azure Data Factoryben és az Azure Synapse Pipelinesban is elérhetők. Ez a cikk az adatfolyamok leképezésére vonatkozik. Ha még nem használta az átalakításokat, tekintse meg az adatok leképezési adatfolyam használatával történő átalakításáról szóló bevezető cikket.

Az alábbi cikkek részletesen ismertetik az Azure Data Factory és az Azure Synapse Analytics által az adatfolyamok leképezésében támogatott ablakfüggvényeket.

Ablakfüggvények listája

Az alábbi függvények csak az ablakátalakításokban érhetők el.

Ablak függvény Task
cumeDist A CumeDist függvény kiszámítja egy érték pozícióját a partíció összes értékéhez viszonyítva. Az eredmény a partíció sorrendjének aktuális sorát megelőző vagy azzal egyenlő sorok száma, osztva az ablakpartícióban lévő sorok teljes számával. A rendezésben szereplő összes döntetlen érték azonos pozícióba kerül.
denseRank Kiszámítja egy érték rangsorát egy ablak sorrendjében megadott értékcsoportban záradék szerint. Az eredmény egy plusz a partíció sorrendjének aktuális sorát megelőző vagy egyenlő sorok száma. Az értékek nem okoznak réseket a sorozatban. A sűrű rangsor akkor is működik, ha az adatok nincsenek rendezve, és az értékek változását keresik.
Lag Lekéri az első kiértékelt n sor értékét az aktuális sor előtt. A második paraméter a visszatekintendő sorok száma, az alapértelmezett érték pedig 1. Ha nincs annyi sor, a rendszer null értéket ad vissza, hacsak nincs megadva alapértelmezett érték.
Vezet Lekéri az aktuális sor után kiértékelt első paraméter n sorainak értékét. A második paraméter a megtekintendő sorok száma, az alapértelmezett érték pedig 1. Ha nincs annyi sor, a rendszer null értéket ad vissza, hacsak nincs megadva alapértelmezett érték.
nTile A NTile függvény az egyes ablakpartíciók n sorait legfeljebb 1 és legfeljebb n1 gyűjtőkre osztja. A gyűjtőértékek legfeljebb 1-rel térnek el egymástól. Ha a partíció sorainak száma nem egyenlően oszlik el a gyűjtők számával, akkor a többi érték gyűjtőnként egy lesz elosztva, kezdve az első gyűjtővel. A NTile függvény hasznos a kvartilisek, a decilek és más általános összefoglaló statisztikák kiszámításához tertiles. A függvény két változót számít ki az inicializálás során: Egy normál gyűjtő mérete egy további sort ad hozzá. Mindkét változó az aktuális partíció méretén alapul. A számítási folyamat során a függvény nyomon követi az aktuális sorszámot, az aktuális gyűjtőszámot és azt a sorszámot, amelyen a gyűjtő módosul (bucketThreshold). Amikor az aktuális sor száma eléri a gyűjtő küszöbértékét, a gyűjtő értékét egyvel növeli, a küszöbértéket pedig a gyűjtő méretével növeli (plusz egy plusz, ha az aktuális gyűjtőt ki van jelölve).
Rangot Kiszámítja egy érték rangsorát egy ablak sorrendjében megadott értékcsoportban záradék szerint. Az eredmény egy plusz a partíció sorrendjének aktuális sorát megelőző vagy egyenlő sorok száma. Az értékek réseket eredményeznek a sorozatban. A rangsor akkor is működik, ha az adatok nincsenek rendezve, és az értékek változását keresik.
rowNumber Szekvenciális sorszámozást rendel hozzá egy ablak soraihoz 1-től kezdődően.

Kapcsolódó tartalom