Flow PHP

MergeSortProcessor implements Distributable

Read onlyYes

FinalYes

Distributable: Unlike a Transformer, receives the whole upstream generator, not one batch.

__construct() : mixed
bind() : BoundStep<string|int, Processor>
breaks() : bool: True when process() needs every input row before it emits one: the processor ends its pipeline.
describe() : null|Description: null when the random value generator does not describe.
distribution() : Distribution|null: null when it does not describe.
fromDescription() : static
process() : Generator<string|int, Rows>: Process a stream of Rows and return a new stream.


        public
            array<int, SortColumn>
    $columns


        public
            ExternalSortConfig
    $config


        public
            ExternalSort
    $sort


    public
                    __construct(ExternalSortConfig $config, array<string|int, mixed> $columns, RandomValueGenerator $random) : mixed

$config : ExternalSortConfig: the effective sort config: the operation's own or the frame's
$columns : array<string|int, mixed>
$random : RandomValueGenerator


    public
                    bind(Schema $input) : BoundStep<string|int, Processor>

BoundStep<string|int, Processor>

True when process() needs every input row before it emits one: the processor ends its pipeline.


    public
                    breaks() : bool

bool

null when the random value generator does not describe.


    public
                    describe() : null|Description

null|Description —

null when this instance cannot cross a process boundary (a live client, a custom collaborator)

null when it does not describe.


    public
                    distribution() : Distribution|null

Distribution|null


    public
            static        fromDescription(array<string|int, mixed> $data, Rebuild $rebuild) : static

static

Process a stream of Rows and return a new stream.


    public
                    process(Generator $rows, Backend $backend) : Generator<string|int, Rows>

Generator<string|int, Rows>