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.