問題タブ [trident]

私はリアルタイム データ プロジェクトに取り組んでおり、現在https://github.com/kstyrc/trident-redisの trident-redis ライブラリを使用して、カウント付きのキー セットを保存しています。各キーの緯度と経度の値など、保存したいさらに高度な内訳がいくつかあります。コマンドラインでRedisを使用すると、次を使用できます。

取得するため

と

trident-redis を使用してこれと同じ効果を得るにはどうすればよいですか? 現在、私のトポロジは次のようになっています。

2 つのストリームをマージすると class のスパウトの 1 つがブロックされる理由を理解する助けが必要FixedBatchSpoutです。

簡単な説明: 2 つのストリーム s1 と s2 をマージしようとしていますが、s2からの(嵐の噴出口) が正常に機能しているように見えますが、s1 の元topology.merge(s1, s2)の (トライデントの噴出口) を呼び出すとブロックされます。FixedBatchSpoutBaseRichSpout

詳細: 以下の main メソッドでは、行を追加するだけで、が最初のバッチを過ぎて出力されるtopology.merge(s1, s2);のを防ぎます。FixedBatchSpoutこれmultireduceも同様に起こります。

助けていただければ幸いです、ありがとう！ジャック

標準のスパウトとボルトの組み合わせを使用してストリーミング集約を行うことができ、ティックタプルを使用して一定の間隔でデータを永続化してバッチ処理を利用する場合、満足のいくケースで非常にうまく機能します。現在、私はいくつかの障害管理（保存されていないタプルの追跡など）を自分で行っています（つまり、嵐からのootbではありません）

しかし、トライデントがより高い抽象化とより優れた障害管理を提供することを読んだことがあります。私が理解していないのは、トライデントにティックタプルのサポートがあるかどうかです。基本的に、現在の分程度のメモリにバッチ処理し、トライデントを使用して前の分の集計データを保持したいと考えています。

ここでの指針やデザインの提案は役に立ちます。

ありがとう

親のないコンポーネントでアニメーション ライブラリTimelineから再生しようとしています。Trident

コンポーネントが親コンテナに配置されるまで、プロパティは補間されません。

上記の環境でタイムラインに「シナリオ」を強制的に実行させる可能性はありますか

トライデント ストームでストリームに関数を適用するには、新しく作成したインスタンスをeach、次のようにストリームで呼び出されるメソッドに渡します。

はSomeFuncBaseFunc の子孫です。

に状態変数が必要だとしますSomeFunc。

SomeFunc コンポーネントの並列処理ヒントを 1 より大きい値に設定すると、SomeFunc?の複数のインスタンスが作成されます。SomeFunc の someState へのアクセス/更新はスレッドセーフ操作ですか? SomeClass をクラスとして定義する代わりにオブジェクトとして定義すると、smth は変更されますか?

編集 OK、彼の回答へのコメントでユーザー @Shaw の助けを借りて、ストームがエグゼキューターごとにストーム コンポーネント (ストーム/ボルト/関数/アグリゲーターなど) のインスタンスを 1 つ作成することを知りました。問題は、これをどのように行うかです。この行動のメカニズムを知りたい

関数の 1 つがフィールドを出力する LocalDRPC で実行されている単純なトライデント トポロジがありますが、それを実行すると、返される結果は、フィールドresultだけではなく、すべてのタプルからのすべての情報であるように見えます。 DRPC docsresultを考えると予想されます。例えば：

すべてのタプルからすべての情報を取得することは問題ありませんが、どのフィールドが結果と呼ばれるかを示すものはありません。現状では、有効な JSON でさえありません!

では、トポロジで指定した特定のフィールドに対応する値を抽出するにはどうすればよいでしょうか?

OpaqueTridentKafkaSpoutとはどう違いTransactionalTridentKafkaSpoutますか？いつどちらを使用しますか？

MQTT ブローカーからデータを受信するトポロジがあり、スパウトを次のように動作させたい:

1. タプルのバッチ (または単一のタプル内の文字列のリスト) を x 秒ごとに発行します。どうすればこれを達成できますか? Storm Trident について少し読みましたがIBatchSpout、特定の時間間隔でタプルをバッチで発行できないようです。

2. 新しいデータが入ってこない場合、スパウトは何をすべきでしょうか? ストームのメイン スレッドなので、スレッドをブロックすることはできませんよね?

私は現在、groupBy と persistentAggregate の後に後処理を行うトライデント トポロジをスケーリングしようとしています。集約ステップの後に newValueStream を使用して値をストリーミングします。groupBy ステップの間、タプルが分割されたままなのか、それとも他の方法で再配布されたのか疑問に思っていました。

関連コード:

Trident (IE11) オブジェクトを使用してアプリで JavaScript をデバッグする方法はありますか? Trident インスタンスを埋め込む (C++/MFC) アプリがあります。正常に動作し、オブジェクトを右クリックすると、通常の IE11 コンテキスト メニューが表示されます。しかし、表示されているページに埋め込まれた JavaScript をデバッグできるように、デバッグ コンソールを起動する方法は明らかではありません。おそらくそれも不可能です。これは、他のプラットフォーム (OSX、UIWebView を使用する iOS、WebView を使用する Android など) でも実行できます。