Hadoop: Remove some unused data members/methods.

diff --git a/src/client/hadoop/ceph/CephFileSystem.java b/src/client/hadoop/ceph/CephFileSystem.java
index 072f4c548c6522831790dbc52472d6548bae6962..98d725e880eabd507c49fff3ef836019316dfffe 100644 (file)
--- a/src/client/hadoop/ceph/CephFileSystem.java
+++ b/src/client/hadoop/ceph/CephFileSystem.java
@@ -75,15 +75,12 @@ public class CephFileSystem extends FileSystem {
   private boolean initialized = false;
 
   private boolean debug = false;
-  private String cephDebugLevel;
-  private String monAddr;
   private String fs_default_name;
   
   private native boolean ceph_initializeClient(String arguments, int block_size);
   private native String  ceph_getcwd();
   private native boolean ceph_setcwd(String path);
   private native boolean ceph_rmdir(String path);
-  private native boolean ceph_mkdir(String path);
   private native boolean ceph_unlink(String path);
   private native boolean ceph_rename(String old_path, String new_path);
   private native boolean ceph_exists(String path);

diff --git a/src/client/hadoop/ceph/CephInputStream.java b/src/client/hadoop/ceph/CephInputStream.java
index c16b614fce3b0249b6c2dcb0e144e5d2d3fc13ad..da75b6d08f945197c514abc82b688ae9b304c466 100644 (file)
--- a/src/client/hadoop/ceph/CephInputStream.java
+++ b/src/client/hadoop/ceph/CephInputStream.java
@@ -39,8 +39,6 @@ import org.apache.hadoop.fs.FSInputStream;
  */
 public class CephInputStream extends FSInputStream {
 
-  private int bufferSize;
-
   private boolean closed;
 
   private int fileHandle;

diff --git a/src/client/hadoop/ceph/CephOutputStream.java b/src/client/hadoop/ceph/CephOutputStream.java
index 99fa68151d5043553c8b3b34c93b873fb3f1c742..6751f71dcca7b1288ac270797d43cdaba4ca97d5 100644 (file)
--- a/src/client/hadoop/ceph/CephOutputStream.java
+++ b/src/client/hadoop/ceph/CephOutputStream.java
@@ -41,8 +41,6 @@ import org.apache.hadoop.util.Progressable;
  */
 public class CephOutputStream extends OutputStream {
 
-  private int bufferSize;
-
   private boolean closed;
 
   private int fileHandle;
@@ -50,7 +48,6 @@ public class CephOutputStream extends OutputStream {
   private boolean debug;
 
 
-  private native long ceph_seek_from_start(int fh, long pos);
   private native long ceph_getpos(int fh);
   private native int ceph_close(int fh);
   private native int ceph_write(int fh, byte[] buffer, int buffer_offset, int length);