加載外部屬性文件中UDF

Question

當編寫一個UDF比方說，一個EvalFunc，是否有可能通過與

properties = new Properties(); 
properties.load(new FileInputStream("conf/config.properties")); 

在Hadoop的模式下運行時

一個配置文件？

最佳， 威爾

Answer 1

這裏是Simple Example to Read and Write files from Hadoop DFS從http://wiki.apache.org/hadoop/HadoopDfsReadWriteExample

也許你可以找到它的一些有用的代碼來完成你的工作。

以下是我的代碼，它成功地加載性能在Hadoop中的文件，我用Apache Commons Configurationhttp://commons.apache.org/configuration/

public static void loadProperites(String path) throws ConfigurationException, IOException { 
    Configuration conf = new Configuration(); 
    FileSystem fs = FileSystem.get(conf); 
    Path inFile = new Path(path); 
    FSDataInputStream in = fs.open(inFile); 

    PropertiesConfiguration config = new PropertiesConfiguration(); 
    config.load(in); 

    in.close(); 
}