flink-streaming

0熱

2答えて

Apache Flink - エラー：メソッドの適用が引数（WindowFunction）に適用されません

Apache Flinkを使用しています。私はApache Kafkaソースからデータを読み込んで、DataStreamを変換する必要があります。 DataStream<Tuple8<Double, Double, String, Double, Double, Double, Double, Double>> dataStream = env .addSour

0熱

1答えて

Flink出力セレクタに異常な動作があります

私は2つのフォークを持つストリームを持っているので、2つのSplitStreamがあります。ここではコードです： static final class MyOutputSelector1 implements OutputSelector<Long> { @Override public Iterable<String> select(Long value) {

0熱

1答えて

フライイングなしでFlinkのタプルがウィンドウなし

がウィンドウ演算子を使用しない場合でも、Flinkはアウトオブオーダーのタプルを処理します？例えば： withTimestampsAndWatermarks .keyBy(...) .map(...) // some stateful function .addSink(...); はmap正しい透かしを受信するまでの要素を処理するために待機するか、待たず

0熱

1答えて

hbaseからの読み取り時にflink thowingシリアル化エラーが発生する

マップ内でrichfatMapFunctionを使用してhbaseから読み込むと、シリアル化エラーが発生します。私がしようとしているのは、datastreamがhbase else ignoreから読み取られた特定の文字列に等しい場合です。以下は、私が得ているサンプルプログラムとエラーです。 package com.abb.Flinktest import java.text.SimpleDat

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、

7熱

1答えて

Flinkストリーミング：開始要素と終了要素で定義されたウィンドウを実装する方法は？私は次の形式でデータを持っている

、 SIP | 2405463430 | 4115474257 | 8.205142580136622E12 |火11月8日夜04時58分58秒 2016 IST | 2405463430 | | 4115474257 | 8.205142580136622E12 | RTPをINVITE火11月8日 16:58:58 IST 2016 | 0 RTP | 2405463430 | 4115474

1熱

1答えて

FLINKストリーミング：（計測をした人に関するメタデータ）</li> </ul> <p>これらはケースクラスですWhoMeasured</p> <ul> <li>測定</li> <li>：別のウィンドウ

内の1つの窓、ルックアップ状態から、私は2つのストリームを持っていますそれらのため： case class Measurement(var value: Int, var who_measured_id: Int) case class WhoMeasured(var who_measured_id: Int, var name: String) Measurementストリームには多くのデ

0熱

1答えて

Apache Flink：ConnectedStreamsのValueStateの範囲

ValueStateメンバーを使用するカスタムRichCoFlatMapFunctionがあります。ドキュメントはを参照してくださいキー/値のインタフェースは、現在の入力要素のキーにスコープされていることを言う https://ci.apache.org/projects/flink/flink-docs-master/dev/state.html#using-the-keyvalue-sta

0熱

3答えて

スカラとApache flinkの新機能、なぜマップ関数がREPLを正しく実行するのですか？Flinkで失敗します

Apache Flinkで単純なhello world型プログラムを実行しようとしています。コードはApache Kafkaからのメッセージを受け取り、 "。"各文字の後に新しい文字列をstdoutに出力します。コードはKafkaからメッセージを正しく取得しますが、マップ関数は "。"を追加します。失敗する。 REPLプロンプトでこの関数を試してみましたが、スカラーコードが正しく機能しています。

1熱

1答えて

Flinkを使用してストリームとバッチ環境を並行して実行する

Flinkでストリームとバッチ処理を並べて実行するのは意味がありますか？ //calculate median using DataSet (Batch Environment) BatchFunctions batch = new BatchFunctions(); DataSet<Tuple2<Double, Integer>> dataSet1 = batch.loadDataSetOf