dbConnection="JDBC0"

<Attr name="transform"><![CDATA[
CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (id INT,surname TEXT,name TEXT);
    TRUNCATE TABLE ${TABLE_NAME};
    SELECT * FROM ${TABLE_NAME};
    ]]> 
</Attr>

Кодировка внешнего файла, указанная в атрибуте sqlQuery.

<Attr name="transform">
    <![CDATA[//#PseudoRust:code 
    Пользовательский алгоритм обработки.
    ]]>
</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}

<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.

Создает выходные записи на основе информации об отдельных записях. Если 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]

целочисленный счетчик (начинается с 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]

string errorMessage

string stackTrace

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

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

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

Вызывается, если updateTransform() вызывает исключение

pub fn update_transform_on_error(_: OutPort) { }

string errorMessage

string stackTrace

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

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

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

Вызывается, если transform() выдает исключение

pub fn transform_on_error(_: OutPort) { }

output.out_0.requestContent = input.in_0.xmlConfig;

<attr name="inputMapping">
    <![CDATA[//#PseudoRust:code

        pub fn transform() -> OutPort {
            output.out_0.requestContent = input.in_0.xmlConfig;

            return out_port![ALL]
        }
    ]]>
</attr>

<attr name="errorMapping">
    <![CDATA[//#PseudoRust:code

        pub fn transform() -> OutPort {
            let message = "Ошибка удаления папки из директории";
            let logType = "ERROR";
            
            output.out_1.message = message;
            output.out_1.logType = logType;

            return out_port![ALL]
        }
    ]]>
</attr>

https://modernsolution.ru

да¹

²

<attr name="inputMapping">
    <![CDATA[//#PseudoRust

        pub fn transform() -> OutPort {
            output.out_0.fileURL = input.in_0.url;

            return out_port![ALL]
        }
    ]]>
</attr>

²

<attr name="standardOutputMapping">
    <![CDATA[//#PseudoRust
        pub fn transform() -> OutPort {
            output.out_0.message[0] = "Файл удален из архива: "+input.in_0.name;
            output.out_0.logType[0] = "INFO";

            return out_port![ALL]
        }
    ]]>
</attr>

²

<attr name="errorOutputMapping"><![CDATA[//#PseudoRust
pub fn transform() -> OutPort {
	output.out_1.message[0] = "Ошибка удаления файла из архива: "+input.in_0.name+"\n"+input.in_1.errorMessage;
	output.out_1.logType[0] = "ERROR";

	return out_port![ALL]
}

]]></attr>

false: если произойдет ошибка (например, файл не найден), шаг продолжит удаление последующих файлов.

true: в случае возникновения ошибки шаг прекратит удаление последующих файлов и отправит информацию об оставшихся неудалёнными файлах на порт ошибки.

Примечание: эта функция работает только в том случае, если к порту ошибки шага подключено ребро.