<attr name="filterExpression">
    <![CDATA[ 
        $in[0].count != 177 && $in[0].product == «карандаш» 
    ]]>
</attr>

¹

<attr name="transform">
    <![CDATA[
        function transform() {
            $out[0].person = $in[0].name.toString() + "_" + $in[0].surname.toString();
            $out[1].person = $in[0].name.toString().toUpperCase() + " " + $in[0].surname.toString().toUpperCase();
            return ALL;
        }
    ]]>
</attr>

<Attr name="transform">
    <![CDATA[//
    Пользовательский алгоритм обработки.
    ]]>
</Attr>

<metadata name> groupAccMd

Метаданные, указанные пользователем. Если groupAccMd не определен, выполнение графа завершится с ошибкой.

pub fn init_group() { }

<metadata name> groupAccumulatorMetadataId

Метаданные, указанные пользователем. Если groupAccMd не определен, выполнение графа завершится с ошибкой.

если true, то вызывается updateTransform(counter, groupAccMd)

если false, то вызывается updateTransformOnError(counter, groupAccMd)

Вызывается многократно (по одному разу для каждой входной записи группы, включая первую и последнюю запись). Вызывается после того, как функция initGroup(groupAccumulator) уже была вызвана для всей группы.

pub fn update_group() -> bool {
    group.count += 1;
    group.sum += input.salary;
return true}

Целочисленный счетчик (начинается с 0, указывает количество созданных записей. Должен быть завершен, как показано в примере ниже. Вызовы функций заканчиваются, когда возвращается SKIP.)

<metadata name> groupAccMd (метаданные, указанные пользователем).

Если groupAccMd не определен, выполнение графа завершится с ошибкой.

Вызывается неоднократно, как указано пользователем. Вызывается после того, как updateGroup(groupAccumulator) возвращает значение true. Функция вызывается до тех пор, пока не будет возвращен SKIP.

Создает выходные записи на основе информации об отдельных записях. Если updateTransform() завершится ошибкой, а updateTransformOnError() не определено, весь граф завершится ошибкой. Если какая-либо часть функции transform() для какой-либо выходной записи вызывает сбой функции updateTransform(), и если определена другая (updateTransformOnError()), обработка продолжается в этом updateTransformOnError() в том месте, где произошел сбой updateTransform(). Функция updateTransformOnError() получает информацию, собранную функцией updateTransform(), полученную из ранее успешно обработанного кода. Сообщение об ошибке и трассировка стека также передаются в updateTransformOnError().

pub fn update_transform(counter: usize) -> OutPort {
    if counter > 1 { 
        return out_port![SKIP] }

    output.out_0 = input.clone();
    return out_port![0]

<metadata name> groupAccMd

Метаданные, указанные пользователем. Если groupAccMd не определен, выполнение графа завершится с ошибкой.

если true, то вызывается transform(counter,groupAccMd)

если false, то вызывается transformOnError(counter,groupAccMd)

Вызывается повторно, один раз для последней входной записи каждой группы. Вызывается после того, как updateGroup(groupAccMd) уже был вызван для всех входных записей группы.

Если finishGroup() завершается с ошибкой, то весь граф завершится ошибкой.

pub fn finish_group() -> bool {
    if input.name.chars().count() < 5 { 
        return false }
        return true}

целочисленный счетчик (начинается с 0, указывает количество созданных записей. должен быть завершен, как показано в примере ниже. Вызовы функций заканчиваются, когда возвращается SKIP.)

<metadata name> groupAccMd (метаданные, указанные пользователем).

Если groupAccMd не определен, выполнение графа завершится с ошибкой.

Вызывается неоднократно, как указано пользователем. Вызывается после того, как updateGroup(groupAccumulator) возвращает значение true. Функция вызывается до тех пор, пока не будет возвращен SKIP.

Создает выходные записи на основе всех записей всей группы. Если функция transform() завершается ошибкой, а функция transformOnError() не определена, весь граф завершится ошибкой. Если какая-либо часть функции transform() для какой-либо выходной записи вызывает сбой функции transform(), и если функция transformOnError() определена, обработка продолжается в transformOnError() в том месте, где произошла ошибка transform(). Функция transformOnError() получает информацию, собранную функцией transform(), которая была получена из ранее успешно обработанного кода. Также сообщение об ошибке и трассировка стека передаются в transformOnError().

pub fn transform(counter: usize) -> OutPort {
    if counter > 0 { 
        return out_port![SKIP] }
        
    output.out_0.name = input.name.clone() + "[AVG]";
    output.out_0.salary = group.sum / (group.count as f64);
    output.out_1 = output.out_0.clone();
    return out_port![ALL]