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
  • 相关阅读:
    webservice时间类型XMLGregorianCalendar和Date的转换
    webservice中jaxws:server 和jaxws:endpoint的区别
    使用CXF开发JAX-WS类型的WebService
    使用TCP/IP Monitor监视Soap协议
    Webservice优缺点总结
    WebService两种调用方法
    DOS命令运行java文件,批量引用jar包
    eclipse创建的maven项目无法部署到tomcat
    图片翻转效果
    掷骰子效果
  • 原文地址:https://www.cnblogs.com/gavinYang/p/11198100.html
Copyright © 2011-2022 走看看