windowing

0熱

1答えて

Flinkストリーミングウィンドウ - 各ウィンドウの最後のイベントは次のウィンドウに属します

私はFlink 1.2-Snapshotを使用しています。 ID = 25398102、ソースID = 1、TS = 2016年10月15日午前〇時00分56秒、ユーザー= 14、値= 919 ID = 25398185、ソースID =：私のデータは以下のようになります。 1、ts = 2016-10-15 00:01:06、user = 14、value = 920 id = 25398210、

0熱

1答えて

ウィンドウ機能

我々はスパークにウィンドウ機能を実装しようとしています。 SparkはKafka（5つのパーティションを持つ）を介してデータを受信しており、処理のためにSpark Java DStreamを使用しています。 kafkaからカンマ区切りのデータをSparkのオブジェクトにマップすると、1秒でスライドする20秒のウィンドウが作成されます。このJava DStreamでは、出力をカウントして出力しま

0熱

1答えて

Apache Flink。ウォーターマークを使用したウィンドウ処理

私は、分秒のタイムスタンプでキー入力された60秒のデータを最大30秒の遅延で集計しようとしています。私はデータを受け取りました。透かしとタイムスタンプが設定されています。集計されたデータはohlcStreamAggregatedに送信されないため、ログに記録されません。 public TimestampExtractor(Time maxDelayInterval) { if

0熱

1答えて

私は次のような構造を持っているPostgresのDB内のテーブルを持っているpostgresの中に複数のグループ

-1熱

1答えて

ハイブウィンドウングORDER BY

こんにちは私はハイブにはとても新しいので、ハイブのWINDOWING機能を学んでいました。私は問題を見つけました。私はクエリを書いた（各ティッカーは22件のレコードを持っていると私は最低のを探していました）各株式相場の最安終値を見つけるためにしようとしていた： SELECT ticker, close FROM (SELECT ticker, close, RANK() OVER (

0熱

1答えて

Azure Stream Analytics - イベントが発生したときの開始/停止/リセットウィンドウ

このロジックを使用してAzure Stream Analytic（ASA）ジョブでルールを作成しようとしています： "値がXとYの間にあり、その範囲を1分間引きしてからサービスバスに出力してください（そしてAzure関数でアラートを送信します）。この値が1分以内に範囲外にある場合は、ウィンドウをリセットする必要があります。私はウィンドウ関数を読んできましたが、ASAの起動時にウィンドウが始まると

1熱

1答えて

tableauの1つ以上のフィールドでパーティショニング

私はtableauの1つ以上のフィールドでパーティショニングする方法を理解できません。データランドスケープ - 私は2次元のフィールドid（string）とplatformtype（str）を持っています。 total_usage（float）とmonth（int）の2つの尺度があります。 MacでTableau Desktop 10.3.3を使用する目標 - 指定した月のtotal_usag

1熱

1答えて

パンダ：ループ内でのローリングカウント

私のデータフレームでは、ローリングマックスとしてカラム '5D_Peak'を作成し、ピークに近い履歴データのローリングカウントを持つ別のカラムを作成したいとします。単純に、または理想的には計算をベクトル化する簡単な方法があるのだろうかと思います。これは、プレーンが、複雑な方法で私のコードです： import numpy as np import pandas as pd df = pd.D

0熱

1答えて

SQLでwindowing関数を使用してレコードを永続化する方法

私は、特定のイベント（ロード）が発生したタイムスタンプに基づいて「セッションID」を作成しようとしているデータセットを持っていますマイデータ： userid event timestamp xyz load '2016-12-01 08:21:13:000' xyz view '2016-12-01 08:21:14:000' xyz view '2016-12-01 08:21:1

2熱

1答えて

不連続シーケンスの最初のレコードを特定するTSQL

私の問題をセットベースで解決するために1 1/2シフトを試みましたが、そこにはかなり到達できませんでした。カーソルで約15分でそれを解決し、それは十分に速く実行されます。しかし、それはセットベースの方法があるのだろうかと思います。私たちは、第三者のHRアプリケーションから抽出された従業員ステータス変更の記録を持っています：empid、recorddate、status。時間の経過とともにemp