Java 类org.apache.hadoop.fs.s3.FileSystemStore 实例源码

public synchronized static FileSystemStore get() {
  if(s != null) {
    return s;
  }
  s = new InMemoryFileSystemStore();
  return s;
}

public S3OutputStream(Configuration conf, FileSystemStore store,
                      Path path, long blockSize, Progressable progress,
                      int buffersize) throws IOException {

  this.conf = conf;
  this.store = store;
  this.path = path;
  this.blockSize = blockSize;
  this.backupFile = newBackupFile();
  this.backupStream = new FileOutputStream(backupFile);
  this.bufferSize = buffersize;
  this.outBuf = new byte[bufferSize];

}

public synchronized static FileSystemStore get() {
  if(s != null) {
    return s;
  }
  s = new InMemoryFileSystemStore();
  return s;
}

public S3OutputStream(Configuration conf, FileSystemStore store,
                      Path path, long blockSize, Progressable progress,
                      int buffersize) throws IOException {

  this.conf = conf;
  this.store = store;
  this.path = path;
  this.blockSize = blockSize;
  this.backupFile = newBackupFile();
  this.backupStream = new FileOutputStream(backupFile);
  this.bufferSize = buffersize;
  this.outBuf = new byte[bufferSize];

}