1

次のように webhdfs ライブラリを使用して、ファイルを hdfs (hadoop ファイル システム) に移動しています。

var hdfsConnector = WebHDFS.createClient(this.config());

var localFileStream = fs.createReadStream(sourcePath);
var remoteFileStream = hdfsConnector.createWriteStream(destinationPath);
localFileStream.pipe(remoteFileStream);

remoteFileStream.on('error', function onError (err) {
    //On error 
});

remoteFileStream.on('finish', function onFinish () {
    //On finish
});

問題は、終了コールバックがそれぞれの場合、つまりエラー時と成功時にトリガーされることです。そのため、成功をどのように識別できますか。

4

0 に答える 0