マッピング データ フローでの順位変換

適用対象: Azure Data Factory Azure Synapse Analytics

ヒント

Data Factory in Microsoft Fabric は、よりシンプルなアーキテクチャ、組み込みの AI、および新機能を備えた次世代のAzure Data Factoryです。 データ統合を初めて使用する場合は、Fabric Data Factory から始めます。 既存の ADF ワークロードをFabricにアップグレードして、データ サイエンス、リアルタイム分析、レポートの新機能にアクセスできます。

データ フローは、Azure Data Factory パイプラインとAzure Synapse Analytics パイプラインの両方で使用できます。 この記事は、マッピング データ フローに適用されます。 変換を初めて使用する場合は、入門記事「 マッピング データ フローを使用したデータの変換」を参照してください。

ヒント

Dataflow Gen2 の同等の変換 (ランク列) については、データ フロー ユーザーのマッピングに関する Dataflow Gen2 のガイドを参照してください。

順位変換を使用して、ユーザーが指定した並べ替え条件に基づいて順序付けされた順位を生成します。

構成

順位設定

大文字と小文字を区別しない: 並べ替え列が文字列型の場合、大文字と小文字が順位付けに組み込まれます。

高 密度： 有効な場合、ランク列は高密度ランク付けされます。 各順位のカウントは連続した数値になり、同順位の場合でも順位値は飛ばされません。

順位列: 生成された順位列の名前。 この列は long 型です。

並べ替え条件： どの列を並べ替えるか、および並べ替えを行う順序を選択してください。 順序によって並べ替えの優先順位が決まります。

この構成では、受信したバスケットボール データを受け取り、"pointsRanking" という名前のランク列を作成します。 列 PTS の値が最も高い行の pointsRanking 値は 1 です。

データ フローのスクリプト

構文

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

例

順位設定

ランク構成のデータ フロー スクリプトは、次のコード スニペットにあります。

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

関連するコンテンツ

フィルター変換を使用して、順位の値に基づいて行をフィルター処理します。

  • Last updated on