問題タブ [flink-streaming]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
flink-streaming - ウィンドウの開始時間と終了時間
ウィンドウの開始時刻と終了時刻を表示するにはどうすればよいでしょうか? ユーザー定義のウィンドウを実装するようなものですか？
出力が
purge - apache fink 0.10タイムウィンドウパージを使用した無限ストリームでの重複のフィルタリング
タイム ウィンドウ パージを使用して無限ストリームで重複を除外するにはどうすればよいですか? 私は無限のスペース/ラムを持っていません.2秒後（ローカルクロックで）、発生する可能性のある重複が発生することを知っています。これは、2 秒後に古いデータを破棄 (パージ) できることを意味します。
タイム ウィンドウ パージを使用した無限ストリームでの重複のフィルタリング。
この質問で重複を削除する方法に対する優れた回答を得ました (Till に感謝します): apache flink 0.10 unbounded input dataStream から複合キーの最初の出現を取得するには?
しかし、2秒後（現地時間）に古いデータを破棄するようにflinkに指示する方法がわかりません。
flink 0.10でこれを行うにはどうすればよいですか?
どうもありがとう！！！
重複を削除するがパージしないステートメントは次のとおりです。
コンパイルできない.timeWindow(Time.minutes(1), Time.seconds(30))後に追加すると。keyBy(0, 1)
java - Apache Flink を使用して Web から JSON 要素を取得する
Apache Flink のいくつかのドキュメント ページ (公式ドキュメント、dataartisans ) と、公式リポジトリで提供されている例を読んだ後、ダウンロード済みのファイルをストリーミングするためのデータ ソースとして使用し、常にローカルホストに接続する例を見続けています。
動的データを含む JSON ファイルをダウンロードするために Apache Flink を使用しようとしています。私の意図は、JSON ファイルを別のシステムでダウンロードして Apache Flink でダウンロードしたファイルを処理するのではなく、Apache Flink の入力ソースとして JSON ファイルにアクセスできる URL を確立しようとすることです。
このネット接続を Apache Flink で確立することは可能ですか?
java - Apache Flink InvocationTargetException: ジョブの実行に失敗しました。接続がタイムアウトしました
この例は、Apache Flink のクイックスタート ガイドから作成しています。私は常にエラーが発生し続けます：
多くの例外は、私がコーディングしているファイルではなく、Flink の内部ファイルから発生します。誰でもこの問題の解決策を教えてもらえますか?
完全な例外は次のとおりです。
activemq - Apache Flink で ActiveMQ を使用するにはどうすればよいですか?
Apache Flink DataStreams を使用してリアルタイムで処理したい ActiveMQ を介してデータを取得しています。RabbitMQ や Kafka などの多くのメッセージング サービスがサポートされていますが、ActiveMQ はサポートされていません。どのように使用できますか？