flink-cep

0熱

1答えて

私は勉強しようとしていますthis Flink CEP例です。私は、この例では、&データを消費する&を生成している単一のアプリケーション（ストリーミングアプリケーションの一種）を作成したことを確認します。彼らは（Kafkaのように）中間にストリーミングレイヤーを配置していません。今のところ、この用途には単一のアプリケーションで十分です。今、私がKafkaを使用すれば、2つのアプリケーションが必要に

2熱

2答えて

Apache Flink結合演算子が間違った応答を返す

私は、汎用レコード型の2つのDataStreamに結合演算子を適用しています。 package com.gslab.com.dataSets; import java.io.File; import java.util.ArrayList; import java.util.List; import org.apache.avro.Schema; import org.apache.av

4熱

2答えて

Apache Flink CEPパターン操作がNOT followBy

私は、2番目のイベントがx秒以内に最初のイベントに従わなかった場合に状態を変更する必要があるシナリオを持っています。例えば、ユーザーが100分でログアウトしなかった場合、彼は無効な状態にあると考えます。どのようにこれは現在のパターン操作を使用して設計できますか？

1熱

2答えて

FLINKのEclipse JDTコンパイラの問題

私はこのプログラムを実行しようとしています：[FLINK CEP監視]を[1] [1]：Amazon EC2の上https://github.com/tillrohrmann/cep-monitoring openjdk1.8 &とFLINK 1.0.2はそれにインストールされています。しかし、このプログラムを実行しようとすると、次の例外がスローされます。「マップ」のジェネリック型パラメータがあ

0熱

1答えて

Apache FlinkのテーブルAPIでCASE WHENを使用するクエリ

私はFlinkのテーブルAPIを使用しています。テーブルAPIクエリでCASE WHENを使用したいと思います。私のクエリでは、routeid, startlocation, distanceという3つのフィールドが使用されており、routeidに基づいて満足するために必要な条件であるdistanceの値に基づいて要因を特定するのにCASE WHEN句を使用します。例： SELECT