bigdata

0熱

1答えて

私はApache hadoop、Hive、Hbaseで2年間の経験を積んでいます。今、私はGoogle Bigqueryで働く機会を得ました。私はBigqueryに入るのは混乱しています。誰かが私が行くべきこととその理由を提案することができますか？

0熱

1答えて

Apache Flink：実行時の状態パラメータを外部から変更する

現在、私はストリーミングMLパイプラインで作業中で、イベント処理は1回だけ必要です。私はFlinkに興味がありましたが、外部から実行状態を変更/更新する方法があるかどうかは疑問です。 mlアルゴリズムの状態はFlinkによって保持されていますが、それは問題ありませんが、実行時に実行パラメータを変更したいと考えているため、実行可能な解決策が見つかりません。基本的に外部Webアプリケーション（GO）は

1熱

2答えて

カッサンドラのデータを別のカサンドラのデータベース（別のサーバー）にコピー

私の質問は上記のとおりで、カサンドラのデータベースを持ち、このデータを持つ別のサーバーを使いたいと思っていました。このキースペースのすべてのデータをどのように移動できますか？私はスナップショットを持っていますが、別のサーバに開くことはできますか？あなたのためのおかげで

0熱

1答えて

Apacheのスパーク - スカラ - HashMapの（K、HashMapの[文字列、ダブル]（V1、V2、...））（（K、V1）、（K、V2）、...）

に私が得た： val vector: RDD[(String, HashMap[String,Double])] = [("a", {("x",1.0),("y", 2.0),...}] それはFlatMapで RDD[String,(String,Double)] = [("a",("x",1.0)), ("a", ("y", 2.0)), ...] を行うことができます方法：は私が取得

0熱

1答えて

2ノードCASandraクラスタで、RF = 1でノードが1つダウンしていると、CL = 1で書き込みできますが、読み取ることはできません。

cassandraを初めて使用しました。私は2つのノードを含むクラスタを持っています。レプリケーションファクタを1に設定しました.1つのノードがダウンすると、エラーなしのデータをConsistency = ONEで挿入できます。私は同じことをTADしようとした場合、挿入した後、それは私にカサンドラは、コーディネータノードからデータを読んでいないのはなぜエラー Unavailable: code=

0熱

1答えて

MongDBは - 私は、すべての個別のuser_idを取得したい、私は私のMongoDBのコレクション（例えばdb.large_collection）</p> <p>で40 MM文書を持っている大規模なコレクション

を照会します。フィールドuser_idにインデックスを作成しましたが、実行しようとするとエラーが返されます。 > db.large_collection.count() 39894523 > db.clean_tweets4.getIndexes() [ { "v" : 1, "key" : { "_id" : 1 }, "name"

1熱

2答えて

IOT用Kafkaクラスタセキュリティ

私はKafkaを初めて使い、IOT用のKafka Productionクラスタを展開したいと考えています。私たちは、ラズベリーパイからインターネットを介してAWSで主催するカフカクラスターへのメッセージを受け取ります。外部のインターネットにKAFKA PORTを開く必要があるので、セキュリティを脅かすようなシステム脅威への道を開いています。インターネット経由でKAFKAポートを使用して悪意のあ

0熱

1答えて

Apacheドリルでハイブ用のストレージプラグインを作成できません

Apacheのドリルに新しいです。Apacheハイブのストレージプラグインを作成中にエラーが発生しました。私は2つの方法を試しました。 1.Firstアプローチ： { "type": "hive", "enabled": false, "configProps": { "hive.metastore.uris": "thrift2:local