Load

Laad slechts drie specifieke velden vanuit een bestand met gegevens met scheidingstekens:

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

Hernoem het eerste veld tot A en het tweede veld tot B bij het laden van een bestand zonder labels:

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

Laad Name als een samenvoeging van FirstName, een spatie en LastName:

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

Laad Quantity, Price en Value (het product van Quantity en Price):

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

Laad alleen unieke records. Dubbele records worden verwijderd:

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

Laad alleen records waarbij het veld Litres een waarde van meer dan nul heeft:

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

Laad een tabel met uitgelijnde gegevens en twee velden met de naam CatID en Category:

LOAD * Inline

[CatID, Category

0,Regular

1,Occasional

2,Permanent];

Laad een tabel met uitgelijnde gegevens en drie velden met de naam UserID, Password en Access:

LOAD * Inline [UserID, Password, Access

A, ABC456, User

B, VIP789, Admin];

Laad een tabel met 10.000 rijen. Veld A bevat het nummer van de ingelezen record (1,2,3,4,5...) en veld B bevat een willekeurig getal tussen 0 en 1:

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

Als eerste laden we een bestand met een tabel met scheidingstekens en geven dat de naam tab1:

tab1:

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

Laad velden vanuit de reeds geladen tabel tab1 als tab2:

tab2:

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

Laad velden uit reeds geladen tabel tab1 maar alleen records waarbij A groter is dan B:

tab3:

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

Laad velden uit al geladen tabel tab1 geordend volgens A:

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

Laad velden vanuit reeds geladen tabel tab1, geordend volgens het eerste veld en vervolgens het tweede veld:

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

Laad veld vanuit reeds geladen tabel tab1 geordend volgens C aflopend, daarna B in oplopende volgorde, en dan het eerste veld in aflopende volgorde:

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

Laad veld Types uit eerder geladen tabel Characters als A:

LOAD A from_field (Characters, Types);

Laad A, B en berekende velden X en Y vanuit Table1 die is geladen in de volgende instructie SELECT:

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

SELECT A,B,C,D from Table1;

Laad velden gegroepeerd (geaggregeerd) op ArtNo:

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

Laad velden gegroepeerd (geaggregeerd) opWeek en ArtNo:

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

In dit voorbeeld hebben we een invoerbestand, Grades.csv, met de cijfers voor elke student gecomprimeerd in één veld:

Student,Grades

Mike,5234

John,3345

Pete,1234

Paul,3352

De cijfers, op een schaal van 1-5, staan voor Math, English, Science en History. We kunnen de cijfers scheiden tot afzonderlijke waarden. Hiervoor lezen we elke record meerdere keren met een while-clausule. We gebruiken de functieIterNo( ) als een teller. Bij elke lezing wordt het cijfer uit de functie Mid gehaald en opgeslagen in Grade en wordt het vak geselecteerd op basis van de functie pick en opgeslagen in Subject. De laatste while-clausule bevat de test waarmee wordt gecontroleerd of alle cijfers zijn gelezen (in dit geval vier per leerling). Dat houdt in dat de volgende leerlingrecord moet worden gelezen.

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

Het resultaat is een tabel met de volgende gegevens:

De onderstaande voorbeeldgegevens worden gebruikt.

Gegevens inladen met een functie

In deze voorbeelden nemen we aan dat we een plugin met de naam P voor analytische verbinding hebben, die een aangepaste functie Calculate(Parameter1, Parameter2) bevat. Deze functie geeft de tabel Results terug met de velden Field1 en Field2.

Hiermee laadt u alle gegevens in die worden teruggegeven nadat de velden A en C naar de functie zijn verzonden.

Hiermee laadt u alleen veld Field1 in de velden A en C naar de functie zijn verzonden.

Hiermee laadt u alle gegevens in die worden teruggegeven nadat de velden A en B naar de functie zijn verzonden. Als velden niet gespecificeerd zijn, worden A en B gebruikt als deze het eerst zijn in de volgorde in de tabel.

Hiermee laadt u alle velden in die worden teruggegeven nadat het veld C naar beide parameters van de functie is verzonden.

Hiermee laadt u alle velden in die worden teruggegeven nadat het veld A geforceerd als tekenreeks en het veld B geforceerd als numeriek naar de functie zijn verzonden.

Gegevens inladen door een script te evalueren

Laad de tabel die door het script q wordt teruggegeven als de waarden van A en B worden verzonden.

Hiermee laadt u de tabel in die door het script wordt teruggegeven in de variabele My_R_Script als de waarden A en B worden verzonden.

Hiermee laadt u de tabel in die door het script wordt teruggegeven in de variabele My_R_Script als de waarden van B worden herbenoemd tot D, A en C. Als u * gebruikt, verzendt u de overgebleven ongekoppelde velden.