data-stream

3熱

2答えて

DSTREAMがunionの2種類を提供ストリーミングスパークでの労働組合の2種類の異なるあります： StreamingContext.union(Dstreams) Dstream.union(anotherDstream) をだから私は、特に並列処理性能で、異なっているかを知りたいです。

0熱

1答えて

SplitStream for dynamic output key（選択）

これは私のコードです。、ストリームを分割しています上記のコードでは30 ... ：80、圧力：70、湿度：80、一時 SplitStream<MonitoringEvent> splitStream = inputStream.split(new OutputSelector<MonitoringEvent>() { @Override public Iterable<St

1熱

2答えて

Apache Flink - x分間のデータがない場合にイベントを送信する

FlinkのDataStream APIを使用して、ある時間ストリームからデータを受信しなかった場合にイベントを送信する演算子を実装するにはどうすればよいですか？

0熱

1答えて

Apache Kafkaのデータストリームジェネレータ

私は、Kafkaブローカのための単純なイベント/データストリームジェネレータを検索して、Hadoopフレームワークのストリーミングツールでいくつかのパフォーマンステストを実行しています。これまで何も適切なものが見つかっていない。非常に短い時間（ミリ秒）で多くの（ほとんど等しい）メッセージを送信できるはずです。ありがとうございます！

0熱

1答えて

R（rredisと特定のソケット）を使用してRedisに接続する方法

私はRedisには全く新しく、Rには比較的新しいです。まずソケットに接続する必要がある割り当てを行う必要があります株式のために）。私は、私は次のエラーを取得するローカルホストに接続しようとR. 毎回で自作を使ってどこでもMy MacでのRedisをインストールした後、パッケージrredis：私はnodelay = F を設定した場合、私が手 redisConnect() Warning mes

1熱

2答えて

CSVファイルからのPythonへのリアルタイムデータストリーム

私は、ランダムセンサーからのデータを数分間で記録したCSVファイルを持っています。今私はCSVファイルから私のpyhtonコードにそのデータをセンサー自体から直接データを受信していたかのようにストリームしたいと思います。（コードは2つの異なるセンサー/ csvファイルから読み込み、平均化するためのコードです）誰かがApache Sparkを使用してデータをストリーミングすることを提案しま

0熱

1答えて

異なる/異なるソースからデータを保存せずにデータを統合/変換する

私はユースケースを持っています。私は異なる/異なるソースからのデータを格納せずに統合/変換したい。データソースはデータベース（oracle、db2など）、Webサービス（Rest/Soap）、フラットファイル（CSV、XML、JSON）、MQダンプ、メインフレームシステムです。私はこれらのソースからデータを引き出し、何らかのインテリジェントな変換と統合を行い、それを顧客に提供したいと考えています。

-1熱

1答えて

Javaソケット（別のクラスのブール値を変更）とデータストリーム

今私はチャットプログラムを作っています。しかし、いくつかの問題があります。最初に、ログインプロセスで、id/pwをサーバに送信すると、サーバはそれが正しいか間違っているか（プロトコル3000または3001）送信します。クライアントはプロトコルを取得します。 islogin(boolean)が変更されます。ただし、ブール値は変更されません。私はなぜそれが変更されていないのか分からない。いくつかの

0熱

1答えて

は、Java

（WindowsのVMで）クライアントソケットプログラムでソケットプログラミングを使用して（ホストOS上で）サーバープログラムに（VMで実行されている）クライアントプログラムからのデータの流れを送るには、コードの下あたりと1から10までの整数を生成 public class ClientSocket { public static void main(String[] args)

0熱

1答えて

setCharacteristicNotificationを無効にする方法

私は加速度計からBLEを介してデータを取得するためのアプリケーションを構築しようとしています。アンドロイドデベロッパーサイトごとに、私は、関数setCharacteristicNotification(characteristic, true)を使用して、BLEデバイスからのデータストリーミングを開始しています。しかし、setCharacteristicNotification(charact