Load

Załaduj tylko trzy określone pola z rozdzielonego pliku:

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

Zmień nazwę pierwszego pola na A, a drugiego na B podczas ładowania pliku bez etykiet:

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

Załaduj Name jako konkatenację FirstName, znaku spacji i LastName:

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

Załaduj Quantity, Price i Value (wynik Quantity i Price):

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

Załaduj tylko unikatowe rekordy (powielone rekordy zostaną zignorowane):

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

Załaduj tylko te rekordy, w których pole Litres ma wartość powyżej zera:

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

Załaduj tabelę z danymi wbudowanymi, dwoma polami o nazwach CatID i Category:

LOAD * Inline

[CatID, Category

0,Regular

1,Occasional

2,Permanent];

Załaduj tabelę z danymi wbudowanymi, trzema polami o nazwach UserID, Password i Access:

LOAD * Inline [UserID, Password, Access

A, ABC456, User

B, VIP789, Admin];

Załaduj tabelę z 10 000 wierszami. Pole A będzie zawierać numer odczytanego rekordu (1, 2, 3, 4, 5...), a pole B losową liczbę między 0 i 1:

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

Najpierw ładujemy rozdzielony plik tabeli i nadajemy mu nazwę tab1:

tab1:

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

Załaduj pola z wcześniej załadowanej tabeli tab1 jako tab2:

tab2:

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

Załaduj pola z wcześniej załadowanej tabeli tab1, ale tylko rekordy, w których wartość A jest większa niż B:

tab3:

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

Załaduj pola z wcześniej załadowanej tabeli tab1 uporządkowane według A:

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

Załaduj pola z wcześniej załadowanej tabeli tab1, uporządkowane według pierwszego pola, a następnie drugiego pola:

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

Załaduj pola z wcześniej załadowanej tabeli tab1 uporządkowane według C malejąco, a następnie B rosnąco, po czym według pierwszego pola malejąco.

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

Załaduj Types pól z wcześniej załadowanej tabeli Characters jako A:

LOAD A from_field (Characters, Types);

Załaduj A, B oraz obliczone pola X i Y z tabeli Table1 ładowanej w następnej instrukcji SELECT:

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

SELECT A,B,C,D from Table1;

Załaduj pola pogrupowane (zagregowane) według ArtNo:

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

Załaduj pola pogrupowane (zagregowane) według Week i ArtNo:

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

W tym przykładzie mamy plik wejściowy Grades.csv zawierający oceny wszystkich uczniów zebrane w jednym polu.

Student,Grades

Mike,5234

John,3345

Pete,1234

Paul,3352

Oceny, w skali od 1 do 5, reprezentują następujące przedmioty: Math, English, Science i History. Możemy rozdzielić oceny w oddzielne wartości, kilkakrotnie odczytując każdy rekord z klauzulą while przy użyciu funkcji IterNo( ) jako licznika. W każdym odczycie ocena jest wyodrębniana przy użyciu funkcji Mid i zapisywana w Grade, a temat jest wybierany za pomocą funkcji pick i zapisywany w Subject. Ostatnia klauzula while zawiera test celem sprawdzenia, czy wszystkie oceny zostały odczytane (w tym przypadku cztery na ucznia), co oznacza, że należy odczytać rekord następnego ucznia.

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));

W efekcie otrzymuje się tabelę zawierającą następujące dane:

Używane są następujące dane przykładowe.

Ładowanie danych za pomocą funkcji

W tych przykładach zakładamy, że mamy wtyczkę połączeń analitycznych o nazwie P, która zawiera funkcję niestandardową Calculate(Parameter1, Parameter2). Ta funkcja zwraca tabelę Results, która zawiera pola Field1 i Field2.

Załaduj wszystkie pola, które są zwracane po wysłaniu pól A i C do funkcji.

W przypadku wysłania pól A i C do funkcji załaduj tylko pole Field1.

Załaduj wszystkie pola, które są zwracane po wysłaniu pól A i B do funkcji. Pola nie są określone, dlatego używane są pola A i B, ponieważ są pierwsze w kolejności w tabeli.

Załaduj wszystkie pola, które są zwracane po wysłaniu pola C do obu parametrów funkcji.

Załaduj wszystkie pola zwracane w przypadku wysłania do funkcji pola A, względem którego wymuszono traktowanie go jako ciągu znaków, oraz pola B, względem którego wymuszono traktowanie go jako liczbowego.

Ładowanie danych poprzez ocenę skryptu

Załaduj tabelę zwracaną przez skrypt q w przypadku wysłania wartości A i B.

Załaduj tabelę zwracaną przez skrypt zapisywany w zmiennej My_R_Script w przypadku wysłania wartości A i B.

Załaduj tabelę zwracaną przez skrypt zapisywany w zmiennej My_R_Script w przypadku wysłania wartości B, której nazwę zmieniono na D, A i C. Użycie * powoduje wysłanie pozostałych pól, do których nie istnieją odwołania.