数据库

Flink SQL知其所以然:大家都用 Cumulate Window 计算累计指标啦

字号+作者:益华科技来源:IT科技2025-11-05 15:52:51我要评论(0)

复制SELECTUNIX_TIMESTAMP(CAST(window_endASSTRING))*1000aswindow_end, window_start,

Flink SQL知其所以然:大家都用 Cumulate Window 计算累计指标啦
复制SELECT UNIX_TIMESTAMP(CAST(window_end AS STRING)) * 1000 as window_end,知其指标         window_start,         sum(money) as sum_money,        count(distinct id) as count_distinct_id  FROMTABLE(CUMULATE(           TABLE source_table           , DESCRIPTOR(row_time)           , INTERVAL 60SECOND          , INTERVAL 1DAY))  GROUPBY window_start,           window_end  1.2.3.4.5.6.7.8.9.10.11.

1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,请转载时务必注明文章作者和来源,不尊重原创的行为我们将追究责任;3.作者投稿可能会经我们编辑修改或补充。

相关文章
  • 环境:Ubuntu8.04 1.安装build工具 sudo aptitude install build-essential linux-headers-$(uname -r) 2.安装readline zlib libncurses5 apt-get install zlib1g-dev apt-get install libreadline5 libreadline5-dev apt-get install libncurses5 libncurses5-dev 3.安装ruby ruby的源代码下载: http://www.ruby-lang.org/en/downloads/ wget ftp://ftp.ruby-lang.org/pub/ruby/1.8/ruby-1.8.6-p114.tar.gz tar xvfz ruby-1.8.6-p114.tar.gz cd ruby-1.8.6-p114 ./configure --prefix=/usr/local/ruby sudo make sudo make install 安装好以后,加入/usr/local/ruby/bin到操作系统的PATH环境变量中 编辑/etc/environment gedit /etc/environment 在最后面加入: PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/ bin:/sbin:/bin:/usr/games:/usr/local/ruby/bin 执行命令,使环境变量修改生效: source /etc/environment 4.安装gem wget http://rubyforge.org/frs/download.php/29548/rubygems-1.0.1.tgz tar xzvf rubygems-1.0.1.tgz cd rubygems-1.0.1 sudo ruby setup.rb 验证gem是否安装成功并升级 sudo gem update --system 5.安装rails sudo gem install rails --include-dependencies 安装好rails以后,验证是否安装成功,可以执行: rails –v 确认一下rails的版本。 //========================================= 其实openssl-ruby是ruby的扩展(extension),它不是像其他纯ruby代码一样,可以用gem来安装。一般情况下需要编译才行。 在linux系统下,这是经常碰到的问题,所以必须记住。 对于openssl-ruby的编译。 首先 cd ruby-source/ext/openssl ruby extconf.rb make make install 进行上面的操作需要包:libssl-dev //===================================================== gem mysql 的时候都要安装下面的包 sudo apt-get install libmysqlclient15-dev 也就是说 要编译安装公司的工具包需要操作如何: 1.安装build工具 sudo aptitude install build-essential linux-headers-$(uname -r) 2.安装readline zlib libncurses5 apt-get install zlib1g-dev apt-get install libreadline5 libreadline5-dev apt-get install libncurses5 libncurses5-dev 3.安装 libssl-dev apt-get install libssl-dev 4安装 mysql 编译包 sudo apt-get install libmysqlclient15-dev

    环境:Ubuntu8.04 1.安装build工具 sudo aptitude install build-essential linux-headers-$(uname -r) 2.安装readline zlib libncurses5 apt-get install zlib1g-dev apt-get install libreadline5 libreadline5-dev apt-get install libncurses5 libncurses5-dev 3.安装ruby ruby的源代码下载: http://www.ruby-lang.org/en/downloads/ wget ftp://ftp.ruby-lang.org/pub/ruby/1.8/ruby-1.8.6-p114.tar.gz tar xvfz ruby-1.8.6-p114.tar.gz cd ruby-1.8.6-p114 ./configure --prefix=/usr/local/ruby sudo make sudo make install 安装好以后,加入/usr/local/ruby/bin到操作系统的PATH环境变量中 编辑/etc/environment gedit /etc/environment 在最后面加入: PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/ bin:/sbin:/bin:/usr/games:/usr/local/ruby/bin 执行命令,使环境变量修改生效: source /etc/environment 4.安装gem wget http://rubyforge.org/frs/download.php/29548/rubygems-1.0.1.tgz tar xzvf rubygems-1.0.1.tgz cd rubygems-1.0.1 sudo ruby setup.rb 验证gem是否安装成功并升级 sudo gem update --system 5.安装rails sudo gem install rails --include-dependencies 安装好rails以后,验证是否安装成功,可以执行: rails –v 确认一下rails的版本。 //========================================= 其实openssl-ruby是ruby的扩展(extension),它不是像其他纯ruby代码一样,可以用gem来安装。一般情况下需要编译才行。 在linux系统下,这是经常碰到的问题,所以必须记住。 对于openssl-ruby的编译。 首先 cd ruby-source/ext/openssl ruby extconf.rb make make install 进行上面的操作需要包:libssl-dev //===================================================== gem mysql 的时候都要安装下面的包 sudo apt-get install libmysqlclient15-dev 也就是说 要编译安装公司的工具包需要操作如何: 1.安装build工具 sudo aptitude install build-essential linux-headers-$(uname -r) 2.安装readline zlib libncurses5 apt-get install zlib1g-dev apt-get install libreadline5 libreadline5-dev apt-get install libncurses5 libncurses5-dev 3.安装 libssl-dev apt-get install libssl-dev 4安装 mysql 编译包 sudo apt-get install libmysqlclient15-dev

    2025-11-05 15:35

  • Win7Ghost系统安装教程(轻松学会使用Win7Ghost系统的安装方法)

    Win7Ghost系统安装教程(轻松学会使用Win7Ghost系统的安装方法)

    2025-11-05 15:03

  • F117机械师的品质如何?(了解F117机械师的性能和可靠性)

    F117机械师的品质如何?(了解F117机械师的性能和可靠性)

    2025-11-05 14:20

  • 雷锋金服(揭秘雷锋金服)

    雷锋金服(揭秘雷锋金服)

    2025-11-05 13:52

网友点评
热门资讯