class HDFSFileStreamSource implements FileStreamSource {

	public InputStream getNextInputStream() {
		this.closeFileStream();
		if (this.currentIndex >= (this.filePaths.size()-1)) return null;
		
		this.currentIndex++;
		String filePath = this.filePaths.get(currentIndex);
		
		Path hdfsPath = new Path(filePath);
        FileSystem fs;
        try {
        	fs = FileSystem.get(config);
            fileStream = fs.open(hdfsPath);
        }
        catch(IOException ioe) {
            this.closeFileStream();
            throw new RuntimeException("Failed opening file:"+filePath,ioe);
        }
        
        return fileStream;
	}

	public  HDFSFileStreamSource();

}