Hadoop 库已导入，但无法在 FyleSystem 中设置“get”方法

Question

我正在尝试设置对 HDFS 的调用以使用 FileSystem 从中获取文件：

FileSystem fs = new FileSystem.get(new URI.create(uri), conf);

但是我得到了这两个错误，即使我调用了所有的库

    Error:(46, 39) java: cannot find symbol

    symbol:   class get

    location: class org.apache.hadoop.fs.FileSystem

    Error:(46, 47) java: cannot find symbol

    symbol:   method create(java.lang.String)

    location: class org.apache.commons.httpclient.URI

这适用于 hadoop 2.7.7 版本。我已经尝试导入孔库 org.apache.hadoop.fs.*; ，但仍然是该方法get并且create当我尝试在以下行中使用它们时不存在： FileSystem fs = new FileSystem.get(URI.create(usi), conf)

import org.apache.commons.httpclient.URI;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.fs.*;

import org.apache.hadoop.fs.Path;

import org.apache.hadoop.io.IOUtils;   

public class Test { 

  public static void main(String []args) {

    String uri = "hdfs://localhost:9000/data.json";

    Configuration conf = new Configuration();

    //cannot find symbol get

    //Cannot find symbol create

    FileSystem fs = new FileSystem.get(new URI.create(uri), conf);

    InputStream in = null;

    try {

        in = fs.open(new Path(uri));

        IOUtils.copyBytes(in, System.out, 4096, false);

    } catch (IOException e) {

        e.printStackTrace();

    } finally {

        IOUtils.closeStream(in);

    }

  }

}

这是我的 POM.xml 文件：

    <?xml version="1.0" encoding="UTF-8"?>

    <project xmlns="http://maven.apache.org/POM/4.0.0"

     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<modelVersion>4.0.0</modelVersion>

<groupId>com.boeing.bedl</groupId>

<artifactId>IngestionData</artifactId>

<version>1.0-SNAPSHOT</version>

<dependencies>

    <dependency>

        <groupId>org.apache.hadoop</groupId>

        <artifactId>hadoop-common</artifactId>

        <version>2.7.7</version>

    </dependency>

    <dependency>

        <groupId>org.apache.hadoop</groupId>

        <artifactId>hadoop-yarn-common</artifactId>

        <version>2.7.7</version>

    </dependency>

Answer 1

我会说问题是你已经导入import org.apache.commons.httpclient.URI;而不是java.net.URI这就是为什么您会因为缺少java.net.URI 的一部分的.create方法而收到错误，并且您会在.get方法上收到错误，因为您传递了错误类型的 URI。（我猜想一些 IDE 的自动导入？:)）

Answer 2

你有两个问题。根据@Veselin Davidov 的回答，您必须将导入更改为java.net.URI：import&nbsp;org.apache.commons.httpclient.URI;至import&nbsp;java.net.URI;第二种，你同时使用 new 操作符和静态工厂方法：FileSystem&nbsp;fs&nbsp;=&nbsp;new&nbsp;FileSystem.get(new&nbsp;URI.create(uri),&nbsp;conf);所以你必须改用工厂：FileSystem&nbsp;fs&nbsp;=&nbsp;FileSystem.get(URI.create(uri),&nbsp;conf);