Pozostało:

30:00

Przetwarzanie danych strumieniowych

Weryfikacja znajomości funkcjonowania zapytań EPL

Czas testu: 40 minut

Użytkownik: INF89721

Uwaga: Pytania zostały już wylosowane! Proszę zaznaczyć odpowiedzi i zatwierdzić formularz.

  1. Dany jest strumień zdarzeń StockTick wchodzących do systemu jak na poniższym rysunku.


    Jakie zdarzenia(e) zostaną umieszczone w strumieniu zdarzeń wychodzących (RSTREAM) w 6 sek. dla następującego zapytania:
    select symbol, count(*)
    from StockTick.win:length_batch(3)
    group by symbol

    nic nie zostanie umieszczone
    {symbol=A, count(*)=2}{symbol=B, count(*)=1}
    {symbol=B, count(*)=1}
    {symbol=A, count(*)=1}{symbol=A, count(*)=1}{symbol=B, count(*)=1}

  2. Dany jest strumień zdarzeń StockTick wchodzących do systemu jak na poniższym rysunku.


    Jakie zdarzenia(e) zostaną umieszczone w strumieniu zdarzeń wychodzących (RSTREAM) w 7 sek. dla następującego zapytania:
    select STA.symbol, STA.price+STB.price price
    from StockTick.win:length(3) as STA join StockTick.win:length(2) as STB
    on (STA.symbol = STB.symbol)

    {price=null, STA.symbol=B}{price=8.0, STA.symbol=A}{price=0.0, STA.symbol=A}
    {price=14.0, STA.symbol=A}{price=10.0, STA.symbol=A}
    {price=16.0, STA.symbol=A}{price=8.0, STA.symbol=A}{price=8.0, STA.symbol=A}
    {price=5.0, STA.symbol=A}{price=12.0, STA.symbol=B}

  3. Dany jest strumień zdarzeń StockTick wchodzących do systemu jak na poniższym rysunku.


    W środowisku przetwarzania danych strumieniowych wykonano następujące polecenia:
    create window WinSTA.win:length(3) (summary double)

    insert into WinSTA(summary)
    select STA.price + STB.price as summary
    from StockTick.win:length(2) as STA join StockTick.win:length(2) as STB
    on STA.symbol = STB.symbol
     Jakie zdarzenia(e) zostaną umieszczone w strumieniu zdarzeń wchodzących (ISTREAM) w 6 sek. dla następującego zapytania:
    select sum(summary) as summary
    from WinSTA

    {summary=26.0}
    {summary=20.0}{summary=24.0}{summary=32.0}
    nic nie zostanie umieszczone
    {summary=36.0}

  4. Dany jest strumień zdarzeń StockTick wchodzących do systemu jak na poniższym rysunku.


    Jakie zdarzenia(e) zostaną umieszczone w strumieniu zdarzeń wchodzących (ISTREAM) w 6 sek. dla następującego zapytania:
    select count(*)
    from StockTick.win:length_batch(2)
    where price>2

    nic nie zostanie umieszczone
    {count(*)=2}{count(*)=1}
    {count(*)=3}
    {count(*)=1}

  5. Dany jest strumień zdarzeń StockTick wchodzących do systemu jak na poniższym rysunku.


    Jakie zdarzenia(e) zostaną umieszczone w strumieniu zdarzeń wchodzących (ISTREAM) w 5 sek. dla następującego zapytania:
    select symbol, price
    from StockTick(price>2).win:length_batch(2)

    {price=6.0, symbol=B}
    {price=5.0, symbol=A}{price=6.0, symbol=B}
    {price=0.0, symbol=A}
    {price=6.0, symbol=B}{price=9.0, symbol=A}

  6. Dany jest strumień zdarzeń StockTick wchodzących do systemu jak na poniższym rysunku.


    Jakie zdarzenia(e) zostaną umieszczone w strumieniu zdarzeń wychodzących (RSTREAM) w 6 sek. dla następującego zapytania:
    select symbol, price
    from StockTick.win:length(3)
    where price>2

    {price=5.0, symbol=A}
    {price=6.0, symbol=B}
    {price=9.0, symbol=A}
    {price=0.0, symbol=A}

  7. Dany jest strumień zdarzeń StockTick wchodzących do systemu jak na poniższym rysunku.


    W środowisku przetwarzania danych strumieniowych wykonano następujące polecenia:
    create window WinSTA.win:length(3) (summary double)

    create window WinSTB.win:length(2) (summary double)

    insert into WinSTA(summary)
    select STA.price + STB.price as summary
    from StockTick.win:length(2) as STA join StockTick.win:length(2) as STB
    on STA.symbol = STB.symbol
     insert into WinSTB(summary)
    select rstream sum(summary) as summary
    from WinSTA
     Jakie zdarzenia(e) zostaną umieszczone w strumieniu zdarzeń wchodzących (ISTREAM) w 6 sek. dla następującego zapytania:
    select sum(summary) as summary
    from WinSTB

    {summary=26.0}
    {summary=62.0}
    {summary=74.0}
    nic nie zostanie umieszczone
    {summary=54.0}{summary=52.0}{summary=56.0}

  8. Dany jest strumień zdarzeń StockTick wchodzących do systemu jak na poniższym rysunku.


    Jakie zdarzenia(e) zostaną umieszczone w strumieniu zdarzeń wychodzących (RSTREAM) w 3 sek. dla następującego zapytania:
    select symbol, price from StockTick.win:length_batch(2)

    {price=1.0, symbol=A}{price=6.0, symbol=B}
    {price=1.0, symbol=A}
    {price=9.0, symbol=A}{price=5.0, symbol=A}
    {price=9.0, symbol=A}

  9. Dany jest strumień zdarzeń StockTick wchodzących do systemu jak na poniższym rysunku.


    Jakie zdarzenia(e) zostaną umieszczone w strumieniu zdarzeń wchodzących (ISTREAM) w 7 sek. dla następującego zapytania:
    select STA.symbol, STA.price+STB.price price
    from StockTick as STA unidirectional join StockTick.win:length(3) as STB
    on (STA.symbol = STB.symbol)

    {price=16.0, STA.symbol=A}{price=8.0, STA.symbol=A}{price=8.0, STA.symbol=A}
    {price=16.0, STA.symbol=A}{price=8.0, STA.symbol=A}
    {price=5.0, STA.symbol=A}{price=0.0, STA.symbol=A}
    {price=0.0, STA.symbol=B}

  10. Dany jest strumień zdarzeń StockTick wchodzących do systemu jak na poniższym rysunku.


    Jakie zdarzenia(e) zostaną umieszczone w strumieniu zdarzeń wchodzących (ISTREAM) w 6 sek. dla następującego zapytania:
    select symbol, count(*)
    from StockTick.win:length(3)
    group by symbol having count(*) < 2

    {symbol=A, count(*)=1}
    {symbol=A, count(*)=2}
    {symbol=B, count(*)=1}
    nic nie zostanie umieszczone