Limit: Filter rows using the row position

class txf.Limit(source=None[, limit=1[, offset=0]])

The Limit transform filters out rows based on their position in the stream.

source: Transform or None

The input pipeline. If one is not provided, Limit will generate limit empty rows.

limit: int

The maximum number of input rows to pass through.

offset: int

The number of input rows to skip before counting starts.

Usage:

Limit(p, 10)
Limit(p, 20, 10)

Example

Line
—-—-—-—-–
|| Q01_PARALLEL ||
—-—-—-—-–
Cold run…DONE
1/5…0.083052
2/5…0.079075
3/5…0.079176
4/5…0.078928
5/5…0.079142
—-—-—-—-–
…

Limit(p, 10)

Line
—-—-—-—-–
|| Q01_PARALLEL ||
—-—-—-—-–
Cold run…DONE
1/5…0.083052
2/5…0.079075
3/5…0.079176
4/5…0.078928
5/5…0.079142
—-—-—-—-–