Load

Загрузка только трех указанных полей из файла с разделителями:

LOAD FirstName, LastName, Number from [lib://DataFiles/data1.csv];

Переименование первого поля в A, а второго в B при загрузке файла без меток:

LOAD @1 as A, @2 as B from [lib://DataFiles/data3.txt] (ansi, txt, delimiter is '\t', no labels);

Загрузка Name путем объединения FirstName, символа пробела и LastName:

LOAD FirstName&' '&LastName as Name from [lib://DataFiles/data1.csv];

Загрузка Quantity, Price и Value (продукт Quantity и Price):

LOAD Quantity, Price, Quantity*Price as Value from [lib://DataFiles/data1.csv];

Загрузка только уникальных записей, дубликаты будут удалены:

LOAD distinct FirstName, LastName, Number from [lib://DataFiles/data1.csv];

Загрузка только записей, где поле Litres имеет значение больше нуля:

LOAD * from [lib://DataFiles/Consumption.csv] where Litres>0;

Загрузка таблицы с встроенными данными, двух полей с именами CatID и Category:

LOAD * Inline

[CatID, Category

0,Regular

1,Occasional

2,Permanent];

Загрузка таблицы с встроенными данными, трех полей с именами UserID, Password и Access:

LOAD * Inline [UserID, Password, Access

A, ABC456, User

B, VIP789, Admin];

Загрузка таблицы с 10 000 строк. Поле A будет содержать количество прочитанных записей (1,2,3,4,5...), а поле B будет содержать произвольное число в диапазоне от 0 до 1:

LOAD RecNo( ) as A, rand( ) as B autogenerate(10000);

Сначала мы загружаем табличный файл с разделителями и присваиваем ему имя tab1:

tab1:

SELECT A,B,C,D from [lib://DataFiles/data1.csv];

Загрузка полей из уже загруженной таблицы tab1 в таблицу tab2:

tab2:

LOAD A,B,month(C),A*B+D as E resident tab1;

Загрузка полей из уже загруженной таблицы tab1, но только записей, где A больше B:

tab3:

LOAD A,A+B+C resident tab1 where A>B;

Загрузка полей из уже загруженной таблицы tab1, сортированных по значению A:

LOAD A,B*C as E resident tab1 order by A;

Загрузка полей из уже загруженной таблицы tab1, сортированных по первому полю, а затем по второму полю:

LOAD A,B*C as E resident tab1 order by 1,2;

Загрузка полей из уже загруженной таблицы tab1, сортированных по значению C в порядке убывания, затем по значению B в порядке возрастания, а затем по первому полю в порядке убывания:

LOAD A,B*C as E resident tab1 order by C desc, B asc, 1 desc;

Загрузка поля Types из ранее загруженной таблицы Characters в качестве A:

LOAD A from_field (Characters, Types);

Загрузка полей A, B, а также вычисляемых полей X и Y из таблицы Table1, которая загружается в следующем операторе SELECT:

LOAD A, B, if(C>0,'positive','negative') as X, weekday(D) as Y;

SELECT A,B,C,D from Table1;

Загрузка полей, группированных (агрегированных) по значению ArtNo:

LOAD ArtNo, round(Sum(TransAmount),0.05) as ArtNoTotal from table.csv group by ArtNo;

Загрузка полей, группированных (агрегированных) по значениям Week и ArtNo:

LOAD Week, ArtNo, round(Avg(TransAmount),0.05) as WeekArtNoAverages from table.csv group by Week, ArtNo;

В этом примере имеется входной файл Grades.csv, содержащий оценки для каждого студента, собранные в одном поле:

Student,Grades

Mike,5234

John,3345

Pete,1234

Paul,3352

Оценки по 5-балльной шкале выставлены по предметам: Math, English, Science и History. Оценки можно выделить в отдельные значения путем многократного считывания каждой записи с помощью предложения while, использующего функцию IterNo( ) в качестве счетчика. При каждом считывании оценка извлекается функцией Mid и сохраняется в значении Grade, а предмет выбирается с помощью функции pick и сохраняется в значении Subject. Конечное предложение while содержит проверку на считывание всех оценок (четыре на студента в данном случае), что означает необходимость считывания записи о следующем студенте.

MyTab:

LOAD Student,

mid(Grades,IterNo( ),1) as Grade,

pick(IterNo( ), 'Math', 'English', 'Science', 'History') as Subject from [lib://DataFiles/Grades.csv]

while IsNum(mid(Grades,IterNo(),1));

Результатом будет таблица, содержащая следующие данные:

Используются следующие данные образца.

Загрузка данных при помощи функции

В этих примерах считается, что подключаемый модуль аналитического подключения с именем P содержит пользовательскую функцию Calculate(Parameter1, Parameter2). Функция возвращает таблицу Results, содержащую поля Field1 и Field2.

Загрузка всех полей, возвращенных при отправке полей A и C в функцию.

Загрузка только поля Field1 при отправке полей A и C в функцию.

Загрузка всех полей, возвращенных при отправке полей A и B в функцию. Так как поля не указаны, используются поля A и B, находящиеся на первом месте в таблице.

Загрузка всех полей, возвращенных при отправке поля C в оба параметра функции.

Загрузка всех полей, возвращенных при отправке в функцию поля A, принудительно обозначенного как строковое, и поля B, принудительно обозначенного как числовое.

Загрузка данных при помощи оценки скрипта

Загрузка таблицы, возвращенной скриптом q при отправке значений A и B.

Загрузка таблицы, возвращенной скриптом, сохраненным в переменной My_R_Script при отправке значений A и B.

Загрузка таблицы, возвращенной скриптом, сохраненным в переменной My_R_Script при отправке значений B, переименованных в D, A и C. Использование * приводит к отправке оставшихся полей без ссылки.