stream-processing

1熱

1答えて

Flinkではオペレータ間で状態を共有することが可能かどうか疑問です。たとえば、私はオペレータのキーでパーティショニングをしていて、何らかの理由でパーティションAパーティション内にパーティションCが必要です（図1.a）、またはオペレータの状態が必要です下流オペレータFのC（図1.b）。私はそれがすべてのパーティションにbroadcast記録することが可能である知っています。レコード内に演算子の

-1熱

2答えて

コレクションまたはデータ構造のいずれかがJavaでブロックされていない

イベント処理では、関数は値をコレクションに入れ、別のものは同じコレクションから値を取り出します。アイテムは、ソース（ソケット）から受け取った順序でコレクション内に配置し、同じ方法で読み取る必要があります。そうしないと、結果が変更されます。キューは、ほとんどの人が推薦するコレクションですが、同時にアイテムが追加されるとキューがブロックされるため、追加が完了するまで待たなければならず、効率が悪くなり

2熱

1答えて

イベント処理フレームワークの推奨事項

イベント処理ドメインの新機能です。私は自分の要件に合わせてJavaベースのイベント処理フレームワークを探しています。 Myriadのフレームワーク（Apache Storm、Apache Kafka、RabbitMQなどの伝統的なイベントブローカー）に関するドキュメントとチュートリアルの迷路を見てきました。私は誰も賢明ではない。私の要件は次のとおりです。私は私にプッシュされるイベントのソース（例

3熱

3答えて

Ocamlのstdinに文字を返します

OCamlのC++メソッドistream::putback(char)に相当しますか？ stdinの先頭に文字を追加するにはどうすればよいですか？

3熱

1答えて

Apache ApexでJSONを使用してDAGを作成するにはどうすればよいですか？

私はJSONを使用してDAGインスタンスを作成するためのドキュメントを探していました。どこかの書式に正式な文書がありますか？

1熱

1答えて

Apache Apex最小限の開発環境

Apexアプリケーションを開発してテストするために最低限必要な環境は何ですか？ WindowsにEclipseでの実行は、私はアペックスのarchtypeを使用してApexプロジェクトを生成し、作成されたデフォルトJUnitテストを実行しますが、次のエラーを取得しようとしました：私がインストールされている必要があります他に何 2016-04-05 13:00:02,677 [main] DEBU

3熱

1答えて

Apache Apexの順不同処理

apache-apex documentationには、プロセッサ内のイベントの順序が保存されていることが示されていますが、これは、アウトオブオーダーを可能にするイベント時の概念がないことを意味しますイベントの処理？さらに、出来事はそれらの内容に基づいて優先順位を変更することができますか？特殊フレーズ（たとえば、セキュリティコンテキストでAUTH）を含む場合NiFiはこれを可能にします。これは帯域

3熱

1答えて

debugging apache heron sccheduler

Twitterの主張によると、apache stronと比較してapache heronの最大の利点の1つはdebug-abilityであり、複数のタスクをバンドルする代わりに各spout/boltタスクを1つのHeronインスタンス（JVMプロセス） 1つのJMV（どのように嵐がそれをやっていた）。このアプローチは、トポロジのデバッグに本当に役立ちます。しかし、私の質問は、スケジューラやリソー

2熱

1答えて

どのようにApacheのApexアプリケーションを再起動するには？

apex documentationから、apache apexで起動したアプリは、それぞれkill-app & shutdown-appのコマンドを使用して強制終了またはシャットダウンできることは明らかです。アプリケーションは、その前の状態からそれを再起動する方法、（シャットダウン/殺す）オフになっている？しかし、

5熱

3答えて

Lamina vs Storm

ストリーミング数値データをかなり大量（> 30G /日）処理するためのプロトタイプのリアルタイムモニタを設計しています。私はこれがClojureに書かれたいと思っています。言語が "Observer + State Machine"システムに適しているように思われるので、これがおそらく終わるでしょう。私がフレームワークで見つけた主な候補は、LaminaとStormです。 RiemannとPuls