class FileInputFormat extends RichInputFormat<OT, FileInputSplit> {

	protected FSDataInputStream decorateInputStream(FSDataInputStream inputStream, FileInputSplit fileSplit) throws Throwable {
		// Wrap stream in a extracting (decompressing) stream if file ends with a known compression file extension.
		InflaterInputStreamFactory<?> inflaterInputStreamFactory = getInflaterInputStreamFactory(fileSplit.getPath());
		if (inflaterInputStreamFactory != null) {
			return new InputStreamFSInputWrapper(inflaterInputStreamFactory.create(stream));
		}

		return inputStream;
	}

	public  FileInputFormat();
	protected  FileInputFormat(Path filePath);

}