すべてのプロダクト
Search

このプロダクト

    Realtime Compute for Apache Flink:HOP

    ドキュメントセンター

    Realtime Compute for Apache Flink:HOP

    最終更新日:Jun 21, 2025

    このトピックでは、Realtime Compute for Apache Flink で HOP 関数を使用する方法について説明します。

    定義

    HOP 関数は、ホッピングウィンドウ（スライディングウィンドウとも呼ばれます）を定義するために使用されます。タンブリングウィンドウとは異なり、スライディングウィンドウは互いに重複することができます。

    構文

    GROUP BY 句で HOP 関数を使用して、スライディングウィンドウを定義できます。

    HOP(<time-attr>, <slide-interval>,<size-interval>)

    入力パラメーター

    パラメーター

    説明

    例

    time-attr

    パラメーターは、ストリーム内の有効な時間属性フィールドである必要があります。このパラメーターは、時間が処理時間かイベント時間かを指定します。詳細については、「時間属性」をご参照ください。

    -

    slide-interval

    スライディングウィンドウが移動する間隔。連続するウィンドウ間の時間差を定義します。このパラメーターは、INTERVAL 'num' timeUnit 形式です。

    INTERVAL '10' SECOND は、スライディングウィンドウが移動する間隔が 10 秒であることを示します。

    size-interval

    スライディングウィンドウのサイズまたは期間。各ウィンドウでカバーされる時間範囲を定義します。このパラメーターは、INTERVAL 'num' timeUnit 形式です。

    INTERVAL '5' MINUTE は、ウィンドウの期間が 5 分であることを示します。

    slide-interval パラメーターと size-interval パラメーターの値に基づいて、次のシナリオでスライディングウィンドウを使用できます。

    • slide-interval < size-interval という条件が満たされている場合、ウィンドウは互いに重複し、各要素は複数のウィンドウに割り当てられます。

    • slide-interval = size-interval という条件が満たされている場合、ウィンドウはタンブリングウィンドウになります。

    • slide-interval > size-interval という条件が満たされている場合、ウィンドウはスライディングウィンドウになります。これらのウィンドウは互いに重複せず、ギャップによって区切られます。

    ほとんどの場合、ほとんどの要素は複数のウィンドウに割り当てられ、ウィンドウは互いに重複します。スライディングウィンドウは、移動平均の計算に適しています。たとえば、10 秒ごとに過去 5 分間のデータの平均を計算する場合、slide-interval を 10 秒に設定し、size-interval を 5 分に設定します。

    ウィンドウ識別子関数

    ウィンドウ識別子関数は、ウィンドウの開始時刻、終了時刻、または時間属性を指定します。時間属性は、下位レベルのウィンドウを集計するために使用されます。

    関数

    戻り値の型

    説明

    HOP_START(<time-attr>, <slide-interval>, <size-interval>)

    TIMESTAMP

    ウィンドウの開始時刻を境界値を含めて返します。たとえば、ウィンドウの時間範囲が [00:10, 00:15] の場合、00:10 が返されます。

    HOP_END(<time-attr>, <slide-interval>, <size-interval>)

    TIMESTAMP

    ウィンドウの終了時刻を境界値を含めて返します。たとえば、ウィンドウの時間範囲が [00:00, 00:15] の場合、00:15 が返されます。

    HOP_ROWTIME(<time-attr>, <slide-interval>, <size-interval>)

    TIMESTAMP (rowtime-attr)

    ウィンドウの終了時刻を境界値を除いて返します。たとえば、ウィンドウの時間範囲が (00:00, 00:15) の場合、00:14:59.999 が返されます。戻り値は、時間操作を実行できる基準となる行時間属性です。この関数は、カスケードウィンドウなど、イベント時間に基づいて定義されたウィンドウでのみ使用できます。詳細については、「カスケードウィンドウ」をご参照ください。

    HOP_PROCTIME (<time-attr>, <slide-interval>, <size-interval>)

    TIMESTAMP (rowtime-attr)

    ウィンドウの終了時刻を境界値を除いて返します。たとえば、ウィンドウの時間範囲が (00:00, 00:15) の場合、00:14:59.999 が返されます。戻り値は、時間操作を実行できる基準となる処理時間属性です。この関数は、カスケードウィンドウなど、処理時間に基づいて定義されたウィンドウでのみ使用できます。詳細については、「カスケードウィンドウ」をご参照ください。

    例

    次の例では、1 分ウィンドウが 30 秒ごとに 1 回スライドします。ウィンドウを使用して、30 秒ごとに過去 1 分間のユーザーごとのクリック数をカウントできます。

    • user_clicks テーブルのテストデータ

      username (VARCHAR)

      click_url (VARCHAR)

      eventtime (VARCHAR)

      Jark

      http://taobao.com/xxx

      2024-10-10 10:00:00.0

      Jark

      http://taobao.com/xxx

      2024-10-10 10:00:10.0

      Jark

      http://taobao.com/xxx

      2024-10-10 10:00:49.0

      Jark

      http://taobao.com/xxx

      2024-10-10 10:01:05.0

      Jark

      http://taobao.com/xxx

      2024-10-10 10:01:58.0

      Timo

      http://taobao.com/xxx

      2024-10-10 10:02:10.0

    • テストステートメント

      CREATE TEMPORARY TABLE user_clicks (
  username VARCHAR,
  click_url VARCHAR,
  eventtime VARCHAR,                            
  ts AS TO_TIMESTAMP(eventtime),
  WATERMARK FOR ts AS ts - INTERVAL '2' SECOND   -- 行時間のウォーターマークを定義します。
) WITH (
  'connector' = 'kafka',
  'topic' = '<yourTopic>',
  'properties.bootstrap.servers' = '<brokers>',
  'scan.startup.mode' = 'earliest-offset',
  'format' = 'csv'
);

CREATE TEMPORARY TABLE hop_output (
  window_start TIMESTAMP,
  window_end TIMESTAMP,
  username VARCHAR,
  clicks BIGINT
) WITH (
  'connector'='print',
  'logger'='true'
);

INSERT INTO
    hop_output
SELECT
    HOP_START (ts, INTERVAL '30' SECOND, INTERVAL '1' MINUTE),
    HOP_END (ts, INTERVAL '30' SECOND, INTERVAL '1' MINUTE),
    username,
    COUNT (click_url)
FROM
    user_clicks
GROUP BY
    HOP (ts, INTERVAL '30' SECOND, INTERVAL '1' MINUTE),username;

    • テスト結果

      window_start (TIMESTAMP)

      window_end (TIMESTAMP)

      username (VARCHAR)

      clicks (BIGINT)

      2024-10-10 09:59:30.0①

      2024-10-10 10:00:30.0

      Jark

      2

      2024-10-10 10:00:00.0

      2024-10-10 10:01:00.0

      Jark

      3

      2024-10-10 10:00:30.0

      2024-10-10 10:01:30.0

      Jark

      2

      2024-10-10 10:01:00.0

      2024-10-10 10:02:00.0

      Jark

      2

      2024-10-10 10:01:30.0

      2024-10-10 10:02:30.0②

      Jark

      1

      2024-10-10 10:01:30.0

      2024-10-10 10:02:30.0②

      Timo

      1

      説明

      • ①スライディングウィンドウがデータがウィンドウに入る時刻を読み取れない場合、最初のウィンドウの開始時刻が前方に移動されます。次の式を使用して、開始時刻が前方に移動される時間間隔を計算できます。時間間隔 = ウィンドウ期間 - スライディングステップ

        ウィンドウ期間（秒）

        スライディングステップ（秒）

        イベント時間

        最初のウィンドウの開始時刻

        最初のウィンドウの終了時刻

        120

        30

        2024-07-31 10:00:00.0

        2024-07-31 09:58:30.0

        2024-07-31 10:00:30.0

        60

        10

        2024-07-31 10:00:00.0

        2024-07-31 09:59:10.0

        2024-07-31 10:00:10.0

      • ②タイムスタンプ 2024-10-10 10:02:30.0 の行は、実際には結果に表示されません。これは、ウィンドウ計算がトリガーされていないためです。ウィンドウ計算をトリガーするには、任意のユーザーからの追加レコードが必要です。

        ウィンドウ計算のトリガー時間 ≥ window_end + ウォーターマーク（10:02:32.0 など）