0
私はWebトラフィック分析のためにApache Flinkを使い始めました。/windowApache Flinkチェーンオペレータ
タイムウィンドウを使用して2つ以上のメトリックを要約する方法が見つかりませんでした。 はfollwing例では、コードは、単語の用法を集約 が、私は言葉を集約する何が必要な場合は、書籍、サイトでは、などの名前を付ける...(ストリーム上の1以上メートル)
val keyValuePair = wordsStream.keyBy(0).timeWindow(Time.seconds(15))
ありがとうございます! Flinkで作業するときのベストプラクティスですか?ストームと比較すると2本のボルトでスパウトが似ていますか? –
はい、exacltyです。そしてそれはベストプラクティスの問題ではありません - それを行う唯一の方法です。 :) –
こんにちは@ MatthiasJ.Sax、私はTupple3(key1、key2、count)を持っていると、それらをkey0とkey1(keyBy(x).sum(3).print())私があなたの答えから理解しているように、出力にはまだkey0、key1、countなどの組み合わせが示されていました。意味:このSQLと同等のコードを取得しようとしています。select key0、count(*)、not:select key0、key1、count(*).....意味がありますか? –