Book Image

Mastering Hadoop

By : Sandeep Karanth
Book Image

Mastering Hadoop

By: Sandeep Karanth

Overview of this book

Table of Contents (21 chapters)
Mastering Hadoop
About the Author
About the Reviewers

Implementing an S3 native filesystem in Hadoop

Let's first create InputStream and OutputStream for the filesystem. In our example, we have to connect to the AWS to read and write files to S3.

Hadoop provides us with the FSInputStream class to cater to custom filesystems. We extend this class and override a few methods in the example implementation. A lot of private variables are declared along with the constructor and helper methods to initialize the client as illustrated in the following code snippet. The private variables contain objects that are used to configure and retrieve data from the filesystem. In this example, we use objects such as AmazonS3Client to call REST web APIs on AWS, S3Object as a representation of the remote object on S3, and S3ObjectInputStream representing the object stream to perform the read operation. All the AWS-related classes are present in the and packages. There are a few other private variables such...