limit()函数

limit()返回从每个输入表中指定offset后的前n行。

如果一个输入表中的行数少于offset + n，则limit()返回所有偏移后的行。

函数类型签名

(<-tables: stream[A], n: int, ?offset: int) => stream[A]

参数

n

(必需) 返回的最大行数。

offset

在每个表中跳过的行数，在限制到n之前。默认为0。

tables

输入数据。默认为管道传输数据(<-)。

示例

• 限制结果为每个表中的前三行
• 限制结果为每个输入表中的前三行，在第一行之后

限制结果为每个表中的前三行

import "sampledata"

sampledata.int()
    |> limit(n: 3)

限制结果为每个输入表中的前三行，在第一行之后

import "sampledata"

sampledata.int()
    |> limit(n: 3, offset: 2)