在Hadoop中引用文件可以使用Hadoop的Java API來實現。以下是一個示例代碼:
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
public class HadoopFileReader {
public static void main(String[] args) throws Exception {
// 創建Hadoop配置對象
Configuration conf = new Configuration();
// 創建文件系統對象
FileSystem fs = FileSystem.get(conf);
// 定義要引用的文件路徑
Path filePath = new Path("hdfs://localhost:9000/input/file.txt");
// 打開文件并讀取內容
try (FSDataInputStream inputStream = fs.open(filePath)) {
byte[] buffer = new byte[1024];
int bytesRead = -1;
while ((bytesRead = inputStream.read(buffer)) > 0) {
String line = new String(buffer, 0, bytesRead);
System.out.println(line);
}
}
// 關閉文件系統對象
fs.close();
}
}
注意,需要替換hdfs://localhost:9000/input/file.txt
為你要引用的Hadoop文件的實際路徑。此代碼將讀取文件的內容并將其打印到控制臺。你可以根據自己的需求修改代碼來進行其他操作,如寫入文件、復制文件等。