public class KfsAccess
extends java.lang.Object
Constructor and Description |
---|
KfsAccess(java.lang.String configFn) |
KfsAccess(java.lang.String metaServerHost,
int metaServerPort) |
Modifier and Type | Method and Description |
---|---|
protected void |
finalize() |
static long |
getDefaultIoBufferSize() |
static long |
getDefaultReadAheadSize() |
KfsOutputChannel |
kfs_append(java.lang.String path) |
int |
kfs_cd(java.lang.String path) |
boolean |
kfs_compareChunkReplicas(java.lang.String path,
java.lang.StringBuffer md5sum) |
KfsOutputChannel |
kfs_create(java.lang.String path) |
KfsOutputChannel |
kfs_create(java.lang.String path,
int numReplicas) |
KfsOutputChannel |
kfs_create(java.lang.String path,
int numReplicas,
boolean exclusive) |
KfsOutputChannel |
kfs_create(java.lang.String path,
int numReplicas,
boolean exclusive,
long bufferSize,
long readAheadSize) |
boolean |
kfs_exists(java.lang.String path) |
long |
kfs_filesize(java.lang.String path) |
java.lang.String[][] |
kfs_getDataLocation(java.lang.String path,
long start,
long len) |
long |
kfs_getModificationTime(java.lang.String path) |
short |
kfs_getReplication(java.lang.String path) |
boolean |
kfs_isDirectory(java.lang.String path) |
boolean |
kfs_isFile(java.lang.String path) |
int |
kfs_mkdirs(java.lang.String path) |
KfsInputChannel |
kfs_open(java.lang.String path) |
KfsInputChannel |
kfs_open(java.lang.String path,
long bufferSize,
long readAheadSize) |
java.lang.String[] |
kfs_readdir(java.lang.String path) |
java.lang.String[] |
kfs_readdir(java.lang.String path,
boolean prefetchAttr) |
KfsFileAttr[] |
kfs_readdirplus(java.lang.String path) |
int |
kfs_remove(java.lang.String path) |
int |
kfs_rename(java.lang.String oldpath,
java.lang.String newpath) |
int |
kfs_rename(java.lang.String oldpath,
java.lang.String newpath,
boolean overwrite) |
int |
kfs_rmdir(java.lang.String path) |
int |
kfs_rmdirs(java.lang.String path) |
int |
kfs_setModificationTime(java.lang.String path,
long msecs) |
short |
kfs_setReplication(java.lang.String path,
int numReplicas) |
void |
release() |
static long |
setDefaultIoBufferSize(long size) |
static long |
setDefaultReadAheadSize(long size) |
public KfsAccess(java.lang.String configFn) throws java.io.IOException
java.io.IOException
public KfsAccess(java.lang.String metaServerHost, int metaServerPort) throws java.io.IOException
java.io.IOException
public static final long setDefaultIoBufferSize(long size)
public static final long getDefaultIoBufferSize()
public static final long setDefaultReadAheadSize(long size)
public static final long getDefaultReadAheadSize()
public int kfs_cd(java.lang.String path)
public int kfs_mkdirs(java.lang.String path)
public int kfs_rmdir(java.lang.String path)
public int kfs_rmdirs(java.lang.String path)
public java.lang.String[] kfs_readdir(java.lang.String path)
public java.lang.String[] kfs_readdir(java.lang.String path, boolean prefetchAttr)
public KfsFileAttr[] kfs_readdirplus(java.lang.String path)
public KfsOutputChannel kfs_append(java.lang.String path)
public KfsOutputChannel kfs_create(java.lang.String path)
public KfsOutputChannel kfs_create(java.lang.String path, int numReplicas)
public KfsOutputChannel kfs_create(java.lang.String path, int numReplicas, boolean exclusive)
public boolean kfs_compareChunkReplicas(java.lang.String path, java.lang.StringBuffer md5sum)
public KfsOutputChannel kfs_create(java.lang.String path, int numReplicas, boolean exclusive, long bufferSize, long readAheadSize)
public KfsInputChannel kfs_open(java.lang.String path)
public KfsInputChannel kfs_open(java.lang.String path, long bufferSize, long readAheadSize)
public int kfs_remove(java.lang.String path)
public int kfs_rename(java.lang.String oldpath, java.lang.String newpath)
public int kfs_rename(java.lang.String oldpath, java.lang.String newpath, boolean overwrite)
public boolean kfs_exists(java.lang.String path)
public boolean kfs_isFile(java.lang.String path)
public boolean kfs_isDirectory(java.lang.String path)
public long kfs_filesize(java.lang.String path)
public java.lang.String[][] kfs_getDataLocation(java.lang.String path, long start, long len)
public short kfs_getReplication(java.lang.String path)
public short kfs_setReplication(java.lang.String path, int numReplicas)
public long kfs_getModificationTime(java.lang.String path)
public int kfs_setModificationTime(java.lang.String path, long msecs)
protected void finalize() throws java.lang.Throwable
finalize
in class java.lang.Object
java.lang.Throwable
public void release()
Copyright 2007-2008 Kosmix Corp. All Rights Reserved