//輸出資料的樣例類
case class logevent(ip:string,userid:string,eventtime:long,method:string,url:string)
//定義視窗聚合結果樣例類
case class urlviewcount(url:string,windowend:long,count:long)
object word2 ).assigntimestampsandwatermarks(new boundedoutofordernesstimestampextractor[logevent](time.seconds(60)) )
.keyby(_.url)
.timewindow(time.minutes(1),time.seconds(5))
.aggregate(new count(), new window())
.keyby(_.windowend)
.process(new toppaix(5))
.print()
env.execute()//自定義聚合函式
class count() extends aggregatefunction[logevent,long,long]
//定義乙個狀態liststate，用來儲存所有的urlviewcount
private var urlstate : liststate[urlviewcount] = _
//對初始狀態做個宣告
override def open(parameters: configuration): unit =
override def processelement(value: urlviewcount, ctx: keyedprocessfunction[long, urlviewcount, string]#context, out: collector[string]): unit =
urlstate.clear()
//基於count大小進行排序
val sortedurlview = allurlview.sortwith(_.count > _.count).take(5)
//格式化成string輸出
val result = new stringbuilder
for (elem <- sortedurlview.indices)
thread.sleep(1000)
out.collect(result.tostring())}
}
商品進銷差價 分享商品流通企業建賬訣竅大全
1 現金日記賬及銀行存款日記賬 商品流通企業的現金日記賬及銀行存款日記賬的建立方法與工業企業是相同的。2 總分類賬簿 商品流通企業的總分類賬除了要設定工業企業日常總分類賬簿之外，還要設定 在途物資 庫存商品 商品進銷差價 這三個商品流通企業必須使用的總賬賬簿。如果經常委託他人代銷商品或為他人代銷商品...
為什麼說品牌的前期要懂得製造產品「流量」？
宣傳 不管是做什麼，或者說是賣什麼，在 剛開始創業 的時候都是需要 為自己的品牌產品 做一些宣傳 現在的時代，不是研發的產品 就行了，還需要 被發現 好比禾稈蓋珍珠這個道理，珍珠，掩蓋在禾稈底下，誰會知道？敢情得把禾稈拿開，讓珍珠暴露在陽光底下，這想不被人發現都難吧。s o 產品質量很重要。被發現也...
流量單位的計算
以下資料來自網路整理，便於檢視。bit byte bpsbps ppsgbps 背板頻寬 bit 二進位制 byte 位元組 注 在計算傳輸速率時，直接用1000來換算 1mb 1000 kb 1000,000 bit bps byte per second 電腦一般都以bps顯示速度，但有時會與傳...