這是一個Task

public static void main(String[] args) throws IOException {
	EntityLinkWordMegerBolt csb = new EntityLinkWordMegerBolt();
	FindIterable<Document> documents = BUnit.readInputUnitStream();
	File file =new File("D:\\Projects\\logs\\output_ELWMB.txt");
        file.createNewFile();
        FileOutputStream fileOutputStream = new FileOutputStream(f);
        PrintStream printStream = new PrintStream(fileOutputStream); 
        System.setErr(printStream);
 
		
	      if(documents!=null){
			Map stormConf = BUnit.getStormConfig();
			csb.prepare(stormConf, null);
			int i = 0;
			for(Document document:documents){
				//System.err.println(document);
				UnitStreamTupleImpl tuple = new UnitStreamTupleImpl(JSONObject.parseObject(document.toJson()));
				csb.execute(tuple, new UnitStreamBaiscOutputCollectorImpl(null));
				i++;
			}
			System.out.println("over"+i);
		}
	}
 

過程中遇到了eclipse報錯，無法啟動：

java.lang.OutOfMemoryError: java heap space

解決辦法：找到eclipse安裝目錄下的：eclipse.ini檔案

修改：

-Xms512m
-Xmx2048m

問題解決，大小可根據自己需要來定。