public class HdfsDirectory extends BaseDirectory
| Modifier and Type | Class and Description |
|---|---|
static class |
HdfsDirectory.HdfsIndexInput
Deprecated.
|
| Modifier and Type | Field and Description |
|---|---|
protected org.apache.hadoop.conf.Configuration |
configuration
Deprecated.
|
static int |
DEFAULT_BUFFER_SIZE
Deprecated.
|
protected org.apache.hadoop.fs.Path |
hdfsDirPath
Deprecated.
|
isOpen, lockFactory| Constructor and Description |
|---|
HdfsDirectory(org.apache.hadoop.fs.Path hdfsDirPath,
org.apache.hadoop.conf.Configuration configuration)
Deprecated.
|
HdfsDirectory(org.apache.hadoop.fs.Path hdfsDirPath,
LockFactory lockFactory,
org.apache.hadoop.conf.Configuration configuration,
int bufferSize)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Deprecated.
|
IndexOutput |
createOutput(String name,
IOContext context)
Deprecated.
|
IndexOutput |
createTempOutput(String prefix,
String suffix,
IOContext context)
Deprecated.
|
void |
deleteFile(String name)
Deprecated.
|
boolean |
equals(Object obj)
Deprecated.
|
long |
fileLength(String name)
Deprecated.
|
long |
fileModified(String name)
Deprecated.
|
org.apache.hadoop.conf.Configuration |
getConfiguration()
Deprecated.
|
org.apache.hadoop.fs.FileSystem |
getFileSystem()
Deprecated.
|
org.apache.hadoop.fs.Path |
getHdfsDirPath()
Deprecated.
|
Set<String> |
getPendingDeletions()
Deprecated.
|
int |
hashCode()
Deprecated.
|
boolean |
isClosed()
Deprecated.
Check whether this directory is open or closed.
|
String[] |
listAll()
Deprecated.
|
IndexInput |
openInput(String name,
IOContext context)
Deprecated.
|
void |
rename(String source,
String dest)
Deprecated.
|
void |
sync(Collection<String> names)
Deprecated.
|
void |
syncMetaData()
Deprecated.
|
String |
toString()
Deprecated.
|
ensureOpen, obtainLockcopyFrom, getTempFileName, openChecksumInputpublic static final int DEFAULT_BUFFER_SIZE
protected final org.apache.hadoop.fs.Path hdfsDirPath
protected final org.apache.hadoop.conf.Configuration configuration
public HdfsDirectory(org.apache.hadoop.fs.Path hdfsDirPath,
org.apache.hadoop.conf.Configuration configuration)
throws IOException
IOExceptionpublic HdfsDirectory(org.apache.hadoop.fs.Path hdfsDirPath,
LockFactory lockFactory,
org.apache.hadoop.conf.Configuration configuration,
int bufferSize)
throws IOException
IOExceptionpublic void close()
throws IOException
close in interface Closeableclose in interface AutoCloseableclose in class DirectoryIOExceptionpublic boolean isClosed()
public IndexOutput createOutput(String name, IOContext context) throws IOException
createOutput in class DirectoryIOExceptionpublic IndexOutput createTempOutput(String prefix, String suffix, IOContext context) throws IOException
createTempOutput in class DirectoryIOExceptionpublic IndexInput openInput(String name, IOContext context) throws IOException
openInput in class DirectoryIOExceptionpublic void deleteFile(String name) throws IOException
deleteFile in class DirectoryIOExceptionpublic void rename(String source, String dest) throws IOException
rename in class DirectoryIOExceptionpublic void syncMetaData()
throws IOException
syncMetaData in class DirectoryIOExceptionpublic long fileLength(String name) throws IOException
fileLength in class DirectoryIOExceptionpublic long fileModified(String name) throws IOException
IOExceptionpublic String[] listAll() throws IOException
listAll in class DirectoryIOExceptionpublic org.apache.hadoop.fs.Path getHdfsDirPath()
public org.apache.hadoop.fs.FileSystem getFileSystem()
public org.apache.hadoop.conf.Configuration getConfiguration()
public Set<String> getPendingDeletions()
getPendingDeletions in class Directorypublic void sync(Collection<String> names) throws IOException
sync in class DirectoryIOExceptionpublic String toString()
toString in class BaseDirectoryCopyright © 2000-2021 Apache Software Foundation. All Rights Reserved.