データ接続と統合Pipeline Builder Transformsトップ行

注: 以下の翻訳の正確性は検証されていません。AIPを利用して英語版の原文から機械的に翻訳されたものです。

上位の行

サポート対象: Batch

並べ替えた各パーティションの上位の行を選びます。

トランスフォームカテゴリ: 集計

引数

  • Dataset - 入力データセット。
    Table
  • Partition by columns - 各パーティションを決定するための列のセット。
    Set<列<AnyType>>
  • Sort specification - 各パーティションをどのように並べ替えるかの仕様。少なくとも1つの仕様が必要です。
    List<Tuple<列<AnyType>, Enum<Ascending, Descending>>>
  • オプション Number of rows - 選択する行の数。デフォルトは 1。
    Literal<Integer>

例 1: 基本ケース

引数の値:

  • Dataset: ri.foundry.main.dataset.a
  • Partition by columns: {airline}
  • Sort specification: [(airport, DESCENDING), (miles, ASCENDING)]
  • Number of rows: null

入力:

airlineairportmiles
foundry airwaysJFK1002345
foundry airwaysLHR2221324
new airSFO21356673
new airJFK12323456
foundry airwaysLHR12542352
new airJFK12232355

出力:

airlineairportmiles
foundry airwaysLHR2221324
new airSFO21356673

例 2: 基本ケース

引数の値:

  • Dataset: ri.foundry.main.dataset.a
  • Partition by columns: {}
  • Sort specification: [(airline, DESCENDING), (airport, DESCENDING), (miles, ASCENDING)]
  • Number of rows: 2

入力:

airlineairportmiles
foundry airwaysJFK1002345
foundry airwaysLHR2221324
new airSFO21356673
new airJFK12323456
foundry airwaysLHR12542352
new airJFK12232355

出力:

airlineairportmiles
new airSFO21356673
new airJFK12232355

例 3: 基本ケース

引数の値:

  • Dataset: ri.foundry.main.dataset.a
  • Partition by columns: {}
  • Sort specification: []
  • Number of rows: 1

入力:

airlineairportmiles
foundry airwaysJFK1002345
foundry airwaysLHR2221324
new airSFO21356673
new airJFK12323456
foundry airwaysLHR12542352
new airJFK12232355

出力:

airlineairportmiles
foundry airwaysJFK1002345