Apache StormのSpoutからBoltにファイルを渡すことはできますか？

Question

public class MySpout implements IRichSpout{ 
    private List fileName; //enter code here 

    public void nextTuple(){  
     File file = new File("D:/small progs/tika_document_type_detection.pdf"); 
     fileName.add(file); 
     this.collector.emit(new Values(fileName)); 
    } 

} 

In Bolt 

public class MyBolt implements IRichBolt{ 
    public void execute(Tuple tuple){ 
     FileInputStream stream = new FileInputStream(tuple.getValues(0)); 
     //can i use this stream obj to parse this file(using Apache tika) 
    } 
} 

ここではSpoutからBoltにファイルオブジェクトを渡すことができません。私はこれに何かを見逃していますか？まず最初に私の質問は、SpoutからBoltにオブジェクトを渡すことができます：

SpoutOutCollector collecot.emit(fileName) 

ここで、fileNameはファイルオブジェクトを含むオブジェクトのリストです。

Answer 1

SpoutがListのFileというオブジェクトを生成して、シリアル化されてボルトに送信されるため、コードが機能しません。私はの内容を送っするためにあなたがしたいと思います...それはあなたが望むものではない、

を

public void execute(Tuple tuple){ 
    List<File> files = (List<File>)tuple.getValue(0); 
} 

しかし、私は推測する：このように、ボルトはこのようFileオブジェクトのリストを受け取ることができますSpoutからBoltまでバイト単位でファイルを作成します。

public void execute(Tuple tuple){ 
    Byte b = tuple.getByte(0); 
} 

：

FileInputStream stream = null; 
public void nextTuple() { 
    if(stream == null) { 
     stream = new FileInputStream(new File("...")); 
    } 
    this.collector.emit(new Values(new Byte(stream.read())); 
} 

はもちろん、ボルトは今組につき1バイトを受信します。このためには、Spout.nextTuple()でファイルを開いて、バイトによってそのバイトを読み、EMITを経由して、単一のバイトを放出する必要があります