zoukankan      html  css  js  c++  java
  • storm滑动窗口

    Window滑动方式:

    没有数据不滑动
    windowLength:窗口的时间长度/tuple个数
    slidingInterval:滑动的时间间隔/tuple个数

    withWindow(Duration windowLength)
    1.表示每个tuple滑动一次,滑动的窗口的时间长度是windowLength。

    withWindow(Duration windowLength, Duration slidingInterval)
    2.表示每隔slidingInterval时间,滑动窗口,滑动的窗口的时间长度是windowLength ,没有数据不滑动。

    withWindow(Count windowLength, Count slidingInterval)
    3.表示每隔slidingInterval的tuple数,滑动窗口,滑动的窗口的tuple个数是windowLength ,没有数据不滑动。

    withWindow(Count windowLength)
    4.表示每个tuple滑动一次,滑动的窗口的tuple个数是windowLength。

    withWindow(Count windowLength, Duration slidingInterval)

    5.表示每隔slidingInterval时间,滑动窗口,滑动的窗口的tuple个数是windowLength ,没有数据不滑动。

    withWindow(Duration windowLength, Count slidingInterval)
    6.表示每隔slidingInterval的tuple数,滑动窗口,滑动的窗口的时间长度是windowLength ,没有数据不滑动。

    表示图:例如每5秒滑动一次,滑动窗口大小是10秒

    ........| e1 e2 | e3 e4 e5 e6 | e7 e8 e9 |...
    -5      0       5            10          15   -> time
    |<------- w1 -->|
            |<---------- w2 ----->|
                    |<-------------- w3 ---->|

    TumblingWindow滑动方式:
    withTumblingWindow(BaseWindowedBolt.Count count)
    1.表示间隔count个tuple数之后滑动一次窗口

    withTumblingWindow(BaseWindowedBolt.Duration duration)

    2.表示间隔时长duration之后滑动一次窗口

    表示图:每5秒滑动一次窗口

    | e1 e2 | e3 e4 e5 e6 | e7 e8 e9 |...
    0       5             10         15    -> time
       w1         w2            w3
  • 相关阅读:
    [BZOJ1934][Shoi2007]Vote 善意的投票[最小割]
    [BZOJ1066][SCOI2007]蜥蜴[最大流]
    [BZOJ2818][P2568]Gcd[欧拉函数]
    [BZOJ2208][P4306][JSOI2010]连通数[bitset优化floyd]
    [BZOJ1877][SDOI2009]晨跑[最大流+费用流]
    [BZOJ1040][P2607][ZJOI2008]骑士[树形DP+基环树]
    [BZOJ5347]冒泡排序[思维]
    [BZOJ2875][Noi2012]随机数生成器[等比数列求和+取模]
    [bzoj2809] 派遣
    [bzoj1965] 洗牌
  • 原文地址:https://www.cnblogs.com/gavinYang/p/11198100.html
Copyright © 2011-2022 走看看