Freigeben über


Rangumwandlung in einem Zuordnungsdatenstrom

GILT FÜR: Azure Data Factory Azure Synapse Analytics

Tipp

Testen Sie Data Factory in Microsoft Fabric, eine All-in-One-Analyselösung für Unternehmen. Microsoft Fabric deckt alle Aufgaben ab, von der Datenverschiebung bis hin zu Data Science, Echtzeitanalysen, Business Intelligence und Berichterstellung. Erfahren Sie, wie Sie kostenlos eine neue Testversion starten!

Datenflüsse sind sowohl in Azure Data Factory-Pipelines als auch in Azure Synapse Analytics-Pipelines verfügbar. Dieser Artikel gilt für Datenflusszuordnungen. Wenn Sie mit Transformationen noch nicht fertig sind, lesen Sie den einführungsartikel Transformieren von Daten mithilfe von Zuordnungsdatenflüssen.

Verwenden Sie die Rangtransformation, um eine geordnete Rangfolge basierend auf den vom Benutzer angegebenen Sortierbedingungen zu generieren.

Konfiguration

Rangeinstellungen

Keine Beachtung von Groß-/Kleinschreibung: Wenn eine Sortierspalte vom Typ „String“ ist, wird die Groß-/Kleinschreibung bei der Rangfolge berücksichtigt.

Dicht: Wenn diese Option aktiviert ist, wird die Rangspalte dicht gereiht. Bei jeder Rangzahl handelt es sich um eine fortlaufende Nummer, und die Rangwerte werden nach einem Gleichstand nicht übersprungen.

Rangspalte: Der Name der generierten Rangspalte. Diese Spalte wird vom Typ „Long“ sein.

Sortierbedingungen: Wählen Sie aus, nach welchen Spalten sortiert werden soll und in welcher Reihenfolge die Sortierung erfolgt. Die Reihenfolge bestimmt die Sortierpriorität.

Bei der oben gezeigten Konfiguration werden eingehende Basketballdaten übernommen und eine Rangspalte mit dem Namen „pointsRanking“ erstellt. Die Zeile mit dem höchsten Wert der Spalte PTS weist einen pointsRanking-Wert von 1 auf.

Datenflussskript

Syntax

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

Beispiel

Rangeinstellungen

Der folgende Codeausschnitt zeigt das Datenflussskript für die obige Rangkonfiguration.

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

Filtern Sie Zeilen basierend auf den Rangwerten mithilfe der Filtertransformation.