org.archive.util

Class GeneralURIStreamFactory

java.lang.Object

org.archive.util.GeneralURIStreamFactory

public class GeneralURIStreamFactory
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GeneralURIStreamFactory.HDFSDefaultUri

Method Summary

Methods

Modifier and Type	Method and Description
static SeekableLineReaderFactory	createSeekableStreamFactory(String uri, boolean useNio)
static SeekableLineReaderFactory	createSeekableStreamFactory(String uri, int blockSize, boolean useNio)
static Stream	createStream(String uri)
static Stream	createStream(String uri, long offset)
protected static org.apache.hadoop.fs.FileSystem	initHdfs()
static boolean	isFileURI(String uri)
static boolean	isHdfs(String uri)
static boolean	isHttp(String uri)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

initHdfs

protected static org.apache.hadoop.fs.FileSystem initHdfs()
                                                   throws IOException

Throws:

IOException

isHdfs

public static boolean isHdfs(String uri)

isHttp

public static boolean isHttp(String uri)

isFileURI

public static boolean isFileURI(String uri)

createStream

public static Stream createStream(String uri)
                           throws IOException

Throws:

IOException

createStream

public static Stream createStream(String uri,
                  long offset)
                           throws IOException

Throws:

IOException

createSeekableStreamFactory

public static SeekableLineReaderFactory createSeekableStreamFactory(String uri,
                                                    boolean useNio)
                                                             throws IOException

Throws:

IOException

createSeekableStreamFactory

public static SeekableLineReaderFactory createSeekableStreamFactory(String uri,
                                                    int blockSize,
                                                    boolean useNio)
                                                             throws IOException

Throws:

IOException