<?php

use Flow\ETL\Adapter\Filter\StringEntryEqualsToFilter;
use Flow\ETL\Adapter\FilterRows;
use Flow\ETL\Row;
use Flow\ETL\Rows;

$transformer = new FilterRows(
    new StringEntryEqualsToFilter('status', 'NEW'),
);

$transformer->transform(
    new Rows(
        Row::create(new Row\Entry\StringEntry('status', 'PENDING')),
        Row::create(new Row\Entry\StringEntry('status', 'SHIPPED')),
        Row::create(new Row\Entry\StringEntry('status', 'NEW')),
    )
);