Modifier and Type | Method and Description |
---|---|
InputStream |
ManagedBlockingUfsForwarder.open(String path,
OpenOptions options) |
InputStream |
ManagedBlockingUfsForwarder.openExistingFile(String path,
OpenOptions options) |
Modifier and Type | Method and Description |
---|---|
InputStream |
UfsInputStreamCache.acquire(UnderFileSystem ufs,
String path,
FileId fileId,
OpenOptions openOptions)
Acquires an input stream.
|
InputStream |
ObjectUnderFileSystem.open(String path,
OpenOptions options) |
InputStream |
UnderFileSystemWithLogging.open(String path,
OpenOptions options) |
InputStream |
UnderFileSystem.open(String path,
OpenOptions options)
Opens an
InputStream for a file in under filesystem at the indicated path. |
InputStream |
ConsistentUnderFileSystem.openExistingFile(String path,
OpenOptions options) |
InputStream |
ObjectUnderFileSystem.openExistingFile(String path,
OpenOptions options) |
InputStream |
UnderFileSystemWithLogging.openExistingFile(String path,
OpenOptions options) |
InputStream |
UnderFileSystem.openExistingFile(String path,
OpenOptions options)
Opens an
InputStream for a file in under filesystem at the indicated path. |
protected abstract InputStream |
ObjectUnderFileSystem.openObject(String key,
OpenOptions options,
RetryPolicy retryPolicy)
Internal function to open an input stream to an object.
|
Modifier and Type | Method and Description |
---|---|
InputStream |
CephFSUnderFileSystem.open(String path,
OpenOptions options) |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
COSUnderFileSystem.openObject(String key,
OpenOptions options,
RetryPolicy retryPolicy) |
Modifier and Type | Method and Description |
---|---|
InputStream |
GCSUnderFileSystem.openExistingFile(String path,
OpenOptions options) |
protected InputStream |
GCSUnderFileSystem.openObject(String key,
OpenOptions options,
RetryPolicy retryPolicy) |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
GCSV2UnderFileSystem.openObject(String key,
OpenOptions options,
RetryPolicy retryPolicy) |
Modifier and Type | Method and Description |
---|---|
InputStream |
HdfsUnderFileSystem.open(String path,
OpenOptions options) |
Modifier and Type | Method and Description |
---|---|
InputStream |
LocalUnderFileSystem.open(String path,
OpenOptions options) |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
OBSUnderFileSystem.openObject(String key,
OpenOptions options,
RetryPolicy retryPolicy) |
Modifier and Type | Method and Description |
---|---|
static OpenOptions |
OpenOptions.defaults() |
OpenOptions |
OpenOptions.setLength(long length) |
OpenOptions |
OpenOptions.setOffset(long offset)
Sets the offset from the start of a file to be opened for reading.
|
OpenOptions |
OpenOptions.setPositionShort(boolean positionShort) |
OpenOptions |
OpenOptions.setRecoverFailedOpen(boolean recover) |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
OSSUnderFileSystem.openObject(String key,
OpenOptions options,
RetryPolicy retryPolicy) |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
S3AUnderFileSystem.openObject(String key,
OpenOptions options,
RetryPolicy retryPolicy) |
Copyright © 2023. All Rights Reserved.