SourceCount
FinalYes
Methods
- absorb() : void
- Takes over what $other counted: its rows, its reads still open and whether one was narrowed.
- closed() : void
- count() : Generator<null|Signal, void>
- Counts the rows of $batches into this read, a corrupted record none, forwards a STOP, closed() once exhausted.
- counted() : void
- isComplete() : bool
- Every read ran to its end and none had a limit, a partition filter or a predicate pushed into it.
- opened() : void
- rows() : int
Methods
absorb()
Takes over what $other counted: its rows, its reads still open and whether one was narrowed.
public
absorb(self $other) : void
Parameters
- $other : self
closed()
public
closed() : void
count()
Counts the rows of $batches into this read, a corrupted record none, forwards a STOP, closed() once exhausted.
public
count(Generator<string|int, T> $batches) : Generator<null|Signal, void>
Parameters
- $batches : Generator<string|int, T>
Tags
Return values
Generator<null|Signal, void>counted()
public
counted(int $rows) : void
Parameters
- $rows : int
isComplete()
Every read ran to its end and none had a limit, a partition filter or a predicate pushed into it.
public
isComplete() : bool
Return values
boolopened()
public
opened(bool $narrowed) : void
Parameters
- $narrowed : bool
rows()
public
rows() : int