Megosztás a következőn keresztül:


Átalakítás rangsorolása a leképezési adatfolyamban

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.

A rangátalakítással rendezett rangsort hozhat létre a felhasználó által megadott rendezési feltételek alapján.

Konfiguráció

Rangsor beállításai

Kis- és nagybetűk megkülönböztetése: Ha egy rendezési oszlop típussztringből áll, a rendszer a kis- és nagybetűket a rangsorba veszi.

Sűrű: Ha engedélyezve van, a rang oszlop sűrű lesz. Minden rangszám egymást követő szám lesz, és a rangértékek nem lesznek kihagyva a döntetlen után.

Rangsor oszlop: A létrehozott rangoszlop neve. Ez az oszlop hosszú lesz.

Rendezési feltételek: Válassza ki, hogy mely oszlopok szerint és milyen sorrendben rendezi a rendezést. A sorrend határozza meg a rendezési prioritást.

A fenti konfiguráció felveszi a bejövő kosárlabdaadatokat, és létrehoz egy "pointsRanking" nevű rangoszlopot. A PTS oszlop legmagasabb értékével rendelkező sor 1 pontozási értékkel fog rendelkezni.

Adatfolyamszkript

Syntax

<incomingStream>
    rank(
        desc(<sortColumn1>),
        asc(<sortColumn2>),
        ...,
        caseInsensitive: { true | false }
        dense: { true | false }
        output(<rankColumn> as long)
    ) ~> <sortTransformationName<>

Példa

Rangsor beállításai

A fenti rangkonfiguráció adatfolyam-szkriptje a következő kódrészletben található.

PruneColumns
    rank(
        desc(PTS, true),
        caseInsensitive: false,
        output(pointsRanking as long),
        dense: false
    ) ~> RankByPoints

Sorok szűrése a rangsorértékek alapján a szűrőátalakítás használatával.