Systém správy relačních datových toků - Relational data stream management system

A systém správy relačních datových toků (RDSMS) je distribuovaný v paměti systém pro správu datových toků (DSMS), který je navržen pro použití v souladu se standardy SQL dotazy ke zpracování nestrukturovaných a strukturovaných datových toků v reálném čase. Na rozdíl od SQL dotazů prováděných tradičním způsobem RDBMS, které vracejí výsledek a opouštějí, dotazy SQL prováděné v RDSMS se neopouštějí, generují výsledky nepřetržitě, jakmile jsou k dispozici nová data. Kontinuální dotazy SQL v RDSMS používají funkci SQL Window k analýze, připojení a agregaci datových toků přes pevná nebo posuvná okna. Windows lze zadat jako časově nebo řádkově.

Příklady dotazů RDSMS SQL

Kontinuální dotazy SQL v RDSMS odpovídají ANSI Standardy SQL. Nejběžnější dotaz RDSMS SQL se provádí s deklarativním VYBRAT prohlášení. Kontinuální SQL VYBRAT pracuje na datech v jednom nebo více datových tocích s volitelnými klíčovými slovy a klauzulemi, které zahrnují Z s volitelným PŘIPOJIT SE subclause určit pravidla pro připojení více datových proudů, KDE klauzule a predikát srovnání k omezení záznamů vrácených dotazem, SKUPINA VYTVOŘENÁ promítat proudy se společnými hodnotami do menší sady, MÁM filtrovat záznamy vyplývající z a SKUPINA VYTVOŘENÁ, a SEŘADIT PODLE třídit výsledky.

Následuje příklad kontinuální agregace datových proudů pomocí a VYBRAT dotaz, který agreguje proud senzoru z meteorologické monitorovací stanice. The VYBRATdotaz agreguje minimální, maximální a průměrné hodnoty teploty za jednosekundové časové období a vrací nepřetržitý proud agregovaných výsledků v intervalech jedné sekundy.

VYBRAT PROUD    PODLAHA(POČASÍ.ROWTIME na DRUHÝ) TAK JAKO FLOOR_SECOND,    MIN(TEPLOTA) TAK JAKO MIN_TEMP,    MAX(TEPLOTA) TAK JAKO MAX_TEMP,    AVG(TEPLOTA) TAK JAKO AVG_TEMPZ POČASÍSKUPINA PODLE PODLAHA(POČASÍ.ROWTIME NA DRUHÝ);

RDSMS SQL dotazy také fungují na datových tocích v čase nebo v oknech založených na řádcích. Následující příklad ukazuje druhý spojitý dotaz SQL pomocí OKNO klauzule s trváním jedné sekundy. The OKNO klauzule mění chování dotazu, aby při každém příchodu vydal výsledek pro každý nový záznam. Výstupem je tedy proud postupně aktualizovaných výsledků s nulovou latencí výsledků.

VYBRAT PROUD    ROWTIME,    MIN(TEPLOTA) PŘES W1 TAK JAKO WMIN_TEMP,    MAX(TEPLOTA) PŘES W1 TAK JAKO WMAX_TEMP,    AVG(TEPLOTA) PŘES W1 TAK JAKO WAVG_TEMPZ POČASÍOKNO W1 TAK JAKO ( ROZSAH INTERVAL '1' DRUHÝ PŘEDCHOZÍ );

Viz také

externí odkazy