hazelcast-jet

0熱

1答えて

ストリームを実装するときにaddJar（）メソッドを使用するにはどうすればよいですか？ newJob（）は、DAGを使用する： JobConfig config = new JobConfig(); config.addJar(".."); jet.newJob(dag, config).execute().get(); ストリームは内部のDAGに変更される： IMap<String, L

0熱

1答えて

ヘーゼルキャストジェット頂点の仕組みを見てみるには？

私は数週間前にバッチからストリームに変更する最初のステップとしてv0.4に書いたヘイルキャストのJet 0.3 DAGシステムを改造しようとしています。興味深いことに、突然私はいくつかの奇妙な動作を経験しています。そこでは、頂点が期待どおりに機能するかどうかはわかりません。何が起きているのかを考えてみると、各頂点の内部の仕組みをどのように覗いていくかについてのオプションを見つけることができません。

0熱

2答えて

Hazelcast Jetのエレガントな頂点を定式化する方法

私はヘーゼルキャストジェッツの二重機能の使用法をプロセッサに蓄積するために、私の頭部を包囲しようとしています。最初の試行は簡単な分の比較ですが、私が思いついたのはそんなに不気味です。それを行うより良い方法はありますか？ Vertex min = dag.newVertex("min", accumulate(() -> new myObject(Type.SOME_ENUM,Double

0熱

1答えて

簡単なDAGをHazelcast Jetで使用するには？

ヘイズキャストジェットのDAGで作業しているときに、私は奇妙な問題に遭遇しました。エラーをチェックするために、私は自分のアプローチを完全に愚かにしました。そして、チュートリアルに従ってエッジが機能していないようです。以下のコードはほぼ同じくらい簡単です。 2つの頂点（1つのソース、1つのシンク）、1つのエッジ。ソースがマップから読み取っている場合、シンクはマップに配置する必要があります。 da

0熱

2答えて

Hazelcastで2つの異なるIMapsを結合することは可能ですか？

私は、キーの両方のマップに参加することを望んでいた2つのhazelcastマップ1. MAP2 2. MAP2 を持っています。ヘーゼルキャストでもできますか？は、あなたが参加して何をしたいかの操作あなたは何を意味するか参加したりすることで、あなたに

0熱

1答えて

TCPソケットを開いて、Hazelcast Jetで取得した連続情報を処理する方法

Hazelcast jetを使用してセンサデータを解析しようとしています。そのためには、Tcpソケットを開き、取得した情報を処理する必要があります。

1熱

2答えて

ヘーゼルキャストキーセットストリーミング？

私はHazelcastを初めて使用しています。これを使って、1台のマシンに収まらない可能性がある大きすぎるマップにデータを保存しようとしています。私が実装する必要があるプロセスの1つは、マップ内の各値を調べて、それらを使って何かを実行することです。累積や集計ではなく、すべてのデータを一度に見る必要はありません。メモリに関する懸念事項はありません。私の簡単な実装では、IMap.keySet()を

9熱

2答えて

Hazelcast JetとApache Flinkの違いは何ですか

具体的には、Hazelcast JetはFlinkで解決しない（同様にうまくいきます）逆もまた同様です。

1熱

1答えて

Hazelcast Jet - ユースケース

Hazelcast Jetのユースケースは何ですか？誰もそれを使い始めたのですか？私たちのプロジェクトでは、Keyを保持しているノードでタスクを実行するために、Key-Valueペアを保持している分散マップ用のHazelcastとそれらのキー上の分散コンピューティングを使用しています。 NearCacheソリューションも使用しています。ヘーゼルキャストジェットとはどのような違いがあり、それがど

2熱

1答えて

ハゼルキャストジェットクラスターの新しいノードで仕事を得る方法

誰かが新しいジェットクラスターインスタンスがどのように仕事を始めなければならないと言うことができますか？ユースケース1：：開始ジェットクラスタノード3によっては、すべての3つのノードは、ジョブとプロセスデータユースケース2を開始クラスタジョブをサブミット start第4ノード第四ノード何もしないことが新しい提出ジョブコマンドませんので、どのように新しいクラスタ・インスタンスすでに別