Transformatie van rangordening in gegevensstroom voor mapping

Van toepassing op: Azure Data Factory Azure Synapse Analytics

Tip

Data Factory in Microsoft Fabric is de volgende generatie van Azure Data Factory, met een eenvoudigere architectuur, ingebouwde AI en nieuwe functies. Als u nieuw bent in gegevensintegratie, begint u met Fabric Data Factory. Bestaande ADF-workloads kunnen upgraden naar Fabric om toegang te krijgen tot nieuwe mogelijkheden voor gegevenswetenschap, realtime analyses en rapportage.

Gegevensstromen zijn beschikbaar in zowel Azure Data Factory pijplijnen als Azure Synapse Analytics pijplijnen. Dit artikel is van toepassing op gegevensverwerkingsstromen. Als u nieuw bent met transformaties, raadpleegt u het inleidende artikel Gegevens transformeren met behulp van mapping-dataflows.

Tip

Zie Een handleiding voor Gegevensstroom Gen2 voor het in kaart brengen van gegevensstroomgebruikers voor de equivalente transformatie (rank column) in Dataflow Gen2.

Gebruik de rangschikkingstransformatie om een geordende rangschikking te genereren op basis van sorteervoorwaarden die door de gebruiker zijn opgegeven.

Configuratie

Rangschikkingsinstellingen

Niet hoofdlettergevoelig: Als een sorteerkolom van het type tekenreeks is, wordt case in de rangschikking meegenomen.

Dichte: Als deze optie is ingeschakeld, is de rangschikkingskolom dicht. Elk aantal rangschikkingen is een opeenvolgend getal en rangwaarden worden niet overgeslagen na een gelijkspel.

Rangschikkingskolom: de naam van de gegenereerde rangordekolom. Deze kolom is van het type long.

Sorteervoorwaarden: Kies op welke kolommen u sorteert en in welke volgorde de sortering plaatsvindt. De volgorde bepaalt de sorteerprioriteit.

De configuratie neemt binnenkomende basketbalgegevens en maakt een rangkolom met de naam 'pointsRanking'. De rij met de hoogste waarde van de kolom PTS heeft een pointsRanking-waarde van 1.

Script voor gegevensstroom

Syntaxis

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

Voorbeeld

Rangschikkingsinstellingen

Het gegevensstroomscript voor de rangschikkingsconfiguratie bevindt zich in het volgende codefragment.

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

Rijen filteren op basis van de rangwaarden met behulp van de filtertransformatie.