public class LlapCacheAwareFs
extends org.apache.hadoop.fs.FileSystem
Constructor and Description |
---|
LlapCacheAwareFs() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.fs.FSDataOutputStream |
append(org.apache.hadoop.fs.Path arg0,
int arg1,
org.apache.hadoop.util.Progressable arg2) |
org.apache.hadoop.fs.FSDataOutputStream |
create(org.apache.hadoop.fs.Path arg0,
org.apache.hadoop.fs.permission.FsPermission arg1,
boolean arg2,
int arg3,
short arg4,
long arg5,
org.apache.hadoop.util.Progressable arg6) |
boolean |
delete(org.apache.hadoop.fs.Path arg0,
boolean arg1) |
org.apache.hadoop.fs.FileStatus |
getFileStatus(org.apache.hadoop.fs.Path arg0) |
URI |
getUri() |
org.apache.hadoop.fs.Path |
getWorkingDirectory() |
void |
initialize(URI uri,
org.apache.hadoop.conf.Configuration conf) |
org.apache.hadoop.fs.FileStatus[] |
listStatus(org.apache.hadoop.fs.Path arg0) |
boolean |
mkdirs(org.apache.hadoop.fs.Path arg0,
org.apache.hadoop.fs.permission.FsPermission arg1) |
org.apache.hadoop.fs.FSDataInputStream |
open(org.apache.hadoop.fs.Path path,
int bufferSize) |
static org.apache.hadoop.fs.Path |
registerFile(org.apache.hadoop.hive.common.io.DataCache cache,
org.apache.hadoop.fs.Path path,
Object fileKey,
TreeMap<Long,Long> index,
org.apache.hadoop.conf.Configuration conf,
String tag) |
boolean |
rename(org.apache.hadoop.fs.Path arg0,
org.apache.hadoop.fs.Path arg1) |
void |
setWorkingDirectory(org.apache.hadoop.fs.Path arg0) |
static void |
unregisterFile(org.apache.hadoop.fs.Path cachePath) |
access, addDelegationTokens, append, append, appendFile, areSymlinksEnabled, cancelDeleteOnExit, canonicalizeUri, checkPath, clearStatistics, close, closeAll, closeAllForUGI, completeLocalOutput, concat, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyToLocalFile, copyToLocalFile, copyToLocalFile, create, create, create, create, create, create, create, create, create, create, create, create, createFile, createNewFile, createNonRecursive, createNonRecursive, createNonRecursive, createPathHandle, createSnapshot, createSnapshot, createSymlink, delete, deleteOnExit, deleteSnapshot, enableSymlinks, exists, fixRelativePart, get, get, get, getAclStatus, getAllStatistics, getAllStoragePolicies, getBlockSize, getCanonicalServiceName, getCanonicalUri, getChildFileSystems, getContentSummary, getDefaultBlockSize, getDefaultBlockSize, getDefaultPort, getDefaultReplication, getDefaultReplication, getDefaultUri, getDelegationToken, getFileBlockLocations, getFileBlockLocations, getFileChecksum, getFileChecksum, getFileLinkStatus, getFileSystemClass, getFSofPath, getGlobalStorageStatistics, getHomeDirectory, getInitialWorkingDirectory, getLength, getLinkTarget, getLocal, getName, getNamed, getPathHandle, getQuotaUsage, getReplication, getScheme, getServerDefaults, getServerDefaults, getStatistics, getStatistics, getStatus, getStatus, getStoragePolicy, getStorageStatistics, getTrashRoot, getTrashRoots, getUsed, getUsed, getXAttr, getXAttrs, getXAttrs, globStatus, globStatus, isDirectory, isFile, listCorruptFileBlocks, listFiles, listLocatedStatus, listLocatedStatus, listStatus, listStatus, listStatus, listStatusBatch, listStatusIterator, listXAttrs, makeQualified, mkdirs, mkdirs, modifyAclEntries, moveFromLocalFile, moveFromLocalFile, moveToLocalFile, newInstance, newInstance, newInstance, newInstanceLocal, open, open, open, primitiveCreate, primitiveMkdir, primitiveMkdir, printStatistics, processDeleteOnExit, removeAcl, removeAclEntries, removeDefaultAcl, removeXAttr, rename, renameSnapshot, resolveLink, resolvePath, setAcl, setDefaultUri, setDefaultUri, setOwner, setPermission, setReplication, setStoragePolicy, setTimes, setVerifyChecksum, setWriteChecksum, setXAttr, setXAttr, startLocalOutput, supportsSymlinks, truncate, unsetStoragePolicy
public static final String SCHEME
public static org.apache.hadoop.fs.Path registerFile(org.apache.hadoop.hive.common.io.DataCache cache, org.apache.hadoop.fs.Path path, Object fileKey, TreeMap<Long,Long> index, org.apache.hadoop.conf.Configuration conf, String tag) throws IOException
IOException
public static void unregisterFile(org.apache.hadoop.fs.Path cachePath)
public void initialize(URI uri, org.apache.hadoop.conf.Configuration conf) throws IOException
initialize
in class org.apache.hadoop.fs.FileSystem
IOException
public org.apache.hadoop.fs.FSDataInputStream open(org.apache.hadoop.fs.Path path, int bufferSize) throws IOException
open
in class org.apache.hadoop.fs.FileSystem
IOException
public URI getUri()
getUri
in class org.apache.hadoop.fs.FileSystem
public org.apache.hadoop.fs.Path getWorkingDirectory()
getWorkingDirectory
in class org.apache.hadoop.fs.FileSystem
public void setWorkingDirectory(org.apache.hadoop.fs.Path arg0)
setWorkingDirectory
in class org.apache.hadoop.fs.FileSystem
public org.apache.hadoop.fs.FSDataOutputStream append(org.apache.hadoop.fs.Path arg0, int arg1, org.apache.hadoop.util.Progressable arg2) throws IOException
append
in class org.apache.hadoop.fs.FileSystem
IOException
public org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path arg0, org.apache.hadoop.fs.permission.FsPermission arg1, boolean arg2, int arg3, short arg4, long arg5, org.apache.hadoop.util.Progressable arg6) throws IOException
create
in class org.apache.hadoop.fs.FileSystem
IOException
public boolean delete(org.apache.hadoop.fs.Path arg0, boolean arg1) throws IOException
delete
in class org.apache.hadoop.fs.FileSystem
IOException
public org.apache.hadoop.fs.FileStatus getFileStatus(org.apache.hadoop.fs.Path arg0) throws IOException
getFileStatus
in class org.apache.hadoop.fs.FileSystem
IOException
public org.apache.hadoop.fs.FileStatus[] listStatus(org.apache.hadoop.fs.Path arg0) throws FileNotFoundException, IOException
listStatus
in class org.apache.hadoop.fs.FileSystem
FileNotFoundException
IOException
public boolean mkdirs(org.apache.hadoop.fs.Path arg0, org.apache.hadoop.fs.permission.FsPermission arg1) throws IOException
mkdirs
in class org.apache.hadoop.fs.FileSystem
IOException
public boolean rename(org.apache.hadoop.fs.Path arg0, org.apache.hadoop.fs.Path arg1) throws IOException
rename
in class org.apache.hadoop.fs.FileSystem
IOException
Copyright © 2022 The Apache Software Foundation. All rights reserved.