Przekształcanie rangi w przepływie danych mapowania

DOTYCZY: Azure Data Factory Azure Synapse Analytics

Napiwek

Wypróbuj usługę Data Factory w usłudze Microsoft Fabric — rozwiązanie analityczne typu all-in-one dla przedsiębiorstw. Usługa Microsoft Fabric obejmuje wszystko, od przenoszenia danych do nauki o danych, analizy w czasie rzeczywistym, analizy biznesowej i raportowania. Dowiedz się, jak bezpłatnie rozpocząć nową wersję próbną !

Przepływy danych są dostępne zarówno w usłudze Azure Data Factory, jak i w potokach usługi Azure Synapse. Ten artykuł dotyczy przepływów danych mapowania. Jeśli dopiero zaczynasz transformacje, zapoznaj się z artykułem wprowadzającym Przekształcanie danych przy użyciu przepływu danych mapowania.

Użyj przekształcenia rangi, aby wygenerować uporządkowaną klasyfikację na podstawie warunków sortowania określonych przez użytkownika.

Konfigurowanie

Rank settings

Bez uwzględniania wielkości liter: jeśli kolumna sortowania jest ciągiem typu, wielkość liter zostanie uwzględniona w klasyfikacji.

Gęsta: jeśli ta opcja jest włączona, kolumna rangi będzie gęsta. Każda liczba rangi będzie kolejną liczbą, a wartości rangi nie zostaną pominięte po krawatie.

Kolumna rangi: nazwa wygenerowanej kolumny rangi. Ta kolumna będzie mieć długość.

Warunki sortowania: wybierz kolumny sortowane według i w jakiej kolejności sortowanie ma miejsce. Kolejność określa priorytet sortowania.

Powyższa konfiguracja pobiera przychodzące dane koszykówki i tworzy kolumnę rangi o nazwie "pointsRanking". Wiersz o najwyższej wartości kolumny PTS będzie miał wartość pointRanking 1.

Skrypt przepływu danych

Składnia

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

Przykład

Rank settings

Skrypt przepływu danych dla powyższej konfiguracji klasyfikacji znajduje się w poniższym fragmencie kodu.

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

Filtruj wiersze na podstawie wartości rangi przy użyciu przekształcenia filtru.