In this tutorial I will show you how to connect to remote unsecured HDFS cluster using Java. If you haven’t install hdfs yet follow the tutorial.
POM.xml:
- <dependency>
- <groupId>org.apache.hadoop</groupId>
- <artifactId>hadoop-client</artifactId>
- <version>2.9.1</version>
- </dependency>
Imports:
- import org.apache.hadoop.conf.Configuration;
- import org.apache.hadoop.fs.FileSystem;
- import java.net.URI;
Connect:
- //Setup the configuration object.
- final Configuration config = new Configuration();
- //If you want you can add any properties you want here.
- //Setup the hdfs file system object.
- final FileSystem fs = FileSystem.get(new URI("hdfs://localhost:50070"), config);
- //Do whatever you need to.