apache-flink

0熱

1答えて

Flickinkで、ウィンドウベースの平均（または私が定義した他の関数）を履歴イベントに基づいたストリームで計算したいので、ストリームはEvent-Times （時間ベースを処理していない）：とき ctx.collectWithTimestamp(Datapoint(instrument, bid, ask), time.getMillis) しかし、私は計算（適用機能）を行うときには動作しま

0熱

1答えて

apacheの中心時刻ウィンドウflink

興味のあるイベントが中心のウィンドウを収集することは可能ですか？は、イベントのストリームを想像してみて：特に ....e...........e...E........e...... を私はトリガイベントEとその周辺に興味があります（+ - 数分）：でこのロジックを実装する ....e..........|e...E....|....e......

0熱

1答えて

一度に1つのFLINK CEPパターンが存在する

一度に1つのキーに対して単一のパターンを持つことは可能ですか？例えば、私は、1分のウィンドウ内のどこの条件にマッチする5つのイベントが得られたかどうかをチェックしたいと思います.10分のイベントを分で取得すると、2つのアラートを取得する必要がありますが、6つのアラートが表示されます。すべてのイベントが新しいパターンを引き起こすからです。一度に1つのパターンインスタンスをキーとして使用できますか？

0熱

1答えて

プロジェクトにFlinkをインポートできません

サンプルのFlinkプロジェクトをインストールするために使用しました。 https://github.com/tillrohrmann/flink-project.g8 私はFlinkの摂取アプリケーションの作成を開始し、依存関係について心配する必要はありませんが、逆効果です。このテンプレートを使用しようとしています。私がsbtと同期しようとすると、私はFlinkを見つけることができません（この部

0熱

2答えて

flinkでdelta triggerを使用するには？

私はApacheのFLINK（FLINK 1.3）でdeltatriggerを使用したいが、私はこのコードのいくつかの問題があります。 .trigger(DeltaTrigger.of(100, new DeltaFunction[uniqStruct] { override def getDelta(oldFp: uniqStruct, newFp: uniqStruct): Doub

1熱

1答えて

Apache FlinkでBucketingSinkを使ってORCファイルに書き込む方法は？

私はkafkaメッセージを読み込み、AWS s3のORCファイルにメッセージをダンプするFlinkストリーミングプログラムに取り組んでいます。私は、FlinkのBucketingSinkとORCファイルライターの統合に関する文書はないことを発見しました。このようなORCファイルライタの実装はBucketingSinkで使用できません。ここには何か考えがありますか？

2熱

1答えて

Flinkで非ブロッキングストリーミング

こんにちは、次のように着信データを処理する必要があるFlinkジョブを実行しようとしています。 keyBy()の直後のプロセス演算子では、データのプロパティによっては時間がかかる場合があります。入ってくるデータが異なるID（ストリームに使用されています）を持っていても、処理機能の長い処理コードは他の入力データをブロックします。私はストリーム全体を意味します。 RuleProcessFunction

0熱

1答えて

Hbaseテーブル入力形式のFlink DataSet API - 複数行の読み込み

0熱

1答えて

イベント時間ベースのスライディングウィンドウの最新のウィンドウのみを評価する

スライディングウィンドウを使用してEvenTimeでイベントを処理したい。スライド間隔は24時間で、インクリメントは30分です。問題は、以下のコードでは、イベントごとに48回の計算が行われていることです。我々のケースでは、イベントが順番に来ているので、最新のウィンドウだけを評価する必要があります。おかげで、デヤン public static void processEventsa(

2熱

1答えて

フリンクシンクはバイオのみをサポートしますか？

シンクのinvokeメソッドは、非同期ioを作る方法のようですか？例えば返信Future？例えば、Redisのコネクターが同期Redisのコマンドを実行するためにjedis libにを使用しています： https://github.com/apache/bahir-flink/blob/master/flink-connector-redis/src/main/java/org/apache/f