問題タブ [sink]

Spring XD を使用して、 MailからFileにデータを取り込もうとしています。ストリームの作成は成功していますが、その過程で出力ファイルは作成されません。

私が使用したコマンドは次のとおりです。

これを修正するにはどうすればよいですか?

さらに、 Mail as Sinkを使用すると、同じ問題が発生します。私が行った例では、HTTPをSourceとして使用しました。

私が使用したコマンドは次のとおりです。

あなたのフィードバックは大歓迎です!

spooldir ソースを使用して、.gz ファイルを SpoolDirectory から HDFS に移動しています。私は次の設定を使用しています、

==========================

========================================

そのため、ファイルは HDFS に転送されますが、末尾に time_in_millis.gz 拡張子が追加されます。また、HDFS のファイルを (端末経由でコピーして) ガンジップしようとすると、不明な文字が表示されます。何が起こっているのかわかりません。

1. HDFS への転送後に同じファイル名を維持したい
2. ファイルを解凍して内容を読めるようにしたい

誰か助けてくれませんか？

R言語初心者です。Rでsparkでプログラムを書いています。出力をhdfsパスに保存したいです。sink方法を試してみました

しかし、それはエラーをスローします。どんな助けでも大歓迎です。

正確なエラーメッセージは

http 投稿本文のハッシュを計算し、受信時に同時に解析したいので、次のような関数が必要です。

画像のアップロードを開発したとき、私passthroughSinkは同様の方法で使用しました。しかし、この場合、画像をファイルに保存するコンジットの結果は必要ありません。

一般に、MVar のようなものを使用して fork を実装する方法は知っていますが、これが最適なソリューションであるかどうかはわかりません。

Festival 音声合成プログラムが合成音声を Skype 通話にパイプできるように、PulseAudio を設定する小さな Python スクリプトがあります。これは、話すことができない人が通常の Skype グループ会議で発言できるようにするためです。

それは機能しますが、セットアップを機能させるには、PulseAudio ボリューム コントロール GUI との対話が多く含まれます。ターミナルのスクリプトで PulseAudio ストリームを設定するにはどうすればよいですか?

小さなスクリプトは次のとおりです。

Hortonworksが提供するカスタム Flume ソースとFlume Kafka シンクを介してメッセージを生成し、 Kafka ブローカーに書き込むプロセスを作成しました。 このプロセス中に、KAFKA ブローカーが既に実行されている場合に Flume エージェントを起動すると、すべてのメッセージが Kafka ブローカーに適切に配信されますが、Flume エージェントが既に実行されているときに Kafka ブローカーを起動すると、KAFKA ブローカーはすべてのメッセージを受け取ります。Kafka コンソール コンシューマーを 実行して受信したメッセージの数を確認すると、最初からいくつかのレコードがドロップされ、最後からいくつかのレコードがドロップされていることに気付きました。

Flume.confで複数の組み合わせを試しましたが、それでも期待どおりに動作しています。

以下は、 Flume.confに提供した構成パラメーターです。

また、flume ログの分析を試みたところ、flume メトリクスがPUTおよびTAKEカウントを適切に示していることがわかりました。

この問題を解決するためのポインタがあれば教えてください。
あらかじめご了承ください。

私はデータフレームを持っています。次のコマンドを使用すると、その内容を outputfile.txt に書き込みたいと思います。

次のメッセージが表示されます。

このデータフレームのすべてのコンテンツを txt ファイルに直接書き込むにはどうすればよいですか?

ノードをシンク ノードとして設定するために、次のコードを使用しています。さて、このコードでは、最初のノードのみがシンクとして設定されています。ネットワークで検出された最初のノード (たとえば、3 番目のノード) をシンク ノードとして設定したい場合、どうすればよいですか? また、1 行目の「if」ステートメントの意味を説明していただけますか。これは、クエリの解決に役立つと思います。

1. if(rimeaddr_node_addr.u8[0] == 1 && rimeaddr_node_addr.u8[1] == 0)
2. {
3. printf("私はシンクです\n");
4. collect_set_sink(&tc, 1);
5. }