org.apache.hadoop.fs.Syncable的实例源码

项目：hadoop-oss    文件：CryptoStreamsTestBase.java   

private void syncableCheck() throws IOException {
  OutputStream out = getoutputStream(smallBufferSize);
  try {
    int bytesWritten = dataLen / 3;
    out.write(data,bytesWritten);
    ((Syncable) out).hflush();

    InputStream in = getInputStream(defaultBufferSize);
    verify(in,bytesWritten,data);
    in.close();

    out.write(data,dataLen - bytesWritten);
    ((Syncable) out).hsync();

    in = getInputStream(defaultBufferSize);
    verify(in,dataLen,data);
    in.close();
  } finally {
    out.close();
  }
}

项目：hadoop    文件：CryptoStreamsTestBase.java   

private void syncableCheck() throws IOException {
  OutputStream out = getoutputStream(smallBufferSize);
  try {
    int bytesWritten = dataLen / 3;
    out.write(data,data);
    in.close();
  } finally {
    out.close();
  }
}

项目：aliyun-oss-hadoop-fs    文件：CryptoStreamsTestBase.java   

private void syncableCheck() throws IOException {
  OutputStream out = getoutputStream(smallBufferSize);
  try {
    int bytesWritten = dataLen / 3;
    out.write(data,data);
    in.close();
  } finally {
    out.close();
  }
}

项目：big-c    文件：CryptoStreamsTestBase.java   

private void syncableCheck() throws IOException {
  OutputStream out = getoutputStream(smallBufferSize);
  try {
    int bytesWritten = dataLen / 3;
    out.write(data,data);
    in.close();
  } finally {
    out.close();
  }
}

项目：hadoop-2.6.0-cdh5.4.3    文件：CryptoStreamsTestBase.java   

private void syncableCheck() throws IOException {
  OutputStream out = getoutputStream(smallBufferSize);
  try {
    int bytesWritten = dataLen / 3;
    out.write(data,data);
    in.close();
  } finally {
    out.close();
  }
}

项目：hops    文件：CryptoStreamsTestBase.java   

private void syncableCheck() throws IOException {
  OutputStream out = getoutputStream(smallBufferSize);
  try {
    int bytesWritten = dataLen / 3;
    out.write(data,data);
    in.close();
  } finally {
    out.close();
  }
}

项目：hadoop-oss    文件：CryptoOutputStream.java   

@Override
public void hflush() throws IOException {
  flush();
  if (out instanceof Syncable) {
    ((Syncable)out).hflush();
  }
}

项目：hadoop-oss    文件：CryptoOutputStream.java   

@Override
public void hsync() throws IOException {
  flush();
  if (out instanceof Syncable) {
    ((Syncable)out).hsync();
  }
}

项目：hadoop    文件：SyncableDataOutputStream.java   

@Override
public void hflush() throws IOException {
  if (out instanceof Syncable) {
    ((Syncable) out).hflush();
  } else {
    out.flush();
  }
}

项目：hadoop    文件：SyncableDataOutputStream.java   

@Override
public void hsync() throws IOException {
  if (out instanceof Syncable) {
    ((Syncable) out).hsync();
  } else {
    out.flush();
  }
}

项目：hadoop    文件：CryptoOutputStream.java   

@Override
public void hflush() throws IOException {
  flush();
  if (out instanceof Syncable) {
    ((Syncable)out).hflush();
  }
}

项目：hadoop    文件：CryptoOutputStream.java   

@Override
public void hsync() throws IOException {
  flush();
  if (out instanceof Syncable) {
    ((Syncable)out).hsync();
  }
}

项目：aliyun-oss-hadoop-fs    文件：SyncableDataOutputStream.java   

@Override
public void hflush() throws IOException {
  if (out instanceof Syncable) {
    ((Syncable) out).hflush();
  } else {
    out.flush();
  }
}

项目：aliyun-oss-hadoop-fs    文件：SyncableDataOutputStream.java   

@Override
public void hsync() throws IOException {
  if (out instanceof Syncable) {
    ((Syncable) out).hsync();
  } else {
    out.flush();
  }
}

项目：aliyun-oss-hadoop-fs    文件：CryptoOutputStream.java   

@Override
public void hflush() throws IOException {
  flush();
  if (out instanceof Syncable) {
    ((Syncable)out).hflush();
  }
}

项目：aliyun-oss-hadoop-fs    文件：CryptoOutputStream.java   

@Override
public void hsync() throws IOException {
  flush();
  if (out instanceof Syncable) {
    ((Syncable)out).hsync();
  }
}

项目：big-c    文件：SyncableDataOutputStream.java   

@Override
public void hflush() throws IOException {
  if (out instanceof Syncable) {
    ((Syncable) out).hflush();
  } else {
    out.flush();
  }
}

项目：big-c    文件：SyncableDataOutputStream.java   

@Override
public void hsync() throws IOException {
  if (out instanceof Syncable) {
    ((Syncable) out).hsync();
  } else {
    out.flush();
  }
}

项目：big-c    文件：CryptoOutputStream.java   

@Override
public void hflush() throws IOException {
  flush();
  if (out instanceof Syncable) {
    ((Syncable)out).hflush();
  }
}

项目：big-c    文件：CryptoOutputStream.java   

@Override
public void hsync() throws IOException {
  flush();
  if (out instanceof Syncable) {
    ((Syncable)out).hsync();
  }
}

项目：hadoop-2.6.0-cdh5.4.3    文件：SyncableDataOutputStream.java   

@Override
public void hflush() throws IOException {
  if (out instanceof Syncable) {
    ((Syncable) out).hflush();
  } else {
    out.flush();
  }
}

项目：hadoop-2.6.0-cdh5.4.3    文件：SyncableDataOutputStream.java   

@Override
public void hsync() throws IOException {
  if (out instanceof Syncable) {
    ((Syncable) out).hsync();
  } else {
    out.flush();
  }
}

项目：hadoop-2.6.0-cdh5.4.3    文件：CryptoOutputStream.java   

@Override
public void hflush() throws IOException {
  flush();
  if (out instanceof Syncable) {
    ((Syncable)out).hflush();
  }
}

项目：hadoop-2.6.0-cdh5.4.3    文件：CryptoOutputStream.java   

@Override
public void hsync() throws IOException {
  flush();
  if (out instanceof Syncable) {
    ((Syncable)out).hsync();
  }
}

项目：apex-malhar    文件：FileSystemWAL.java   

protected void flush() throws IOException
{
  if (outputStream != null) {
    if (fileSystemWAL.fileContext.getDefaultFileSystem() instanceof LocalFs ||
        fileSystemWAL.fileContext.getDefaultFileSystem() instanceof RawLocalFs) {
      //until the stream is closed on the local FS,readers don't see any data.
      close();
    } else {
      Syncable syncableOutputStream = (Syncable)outputStream;
      syncableOutputStream.hflush();
      syncableOutputStream.hsync();
    }
  }
}

项目：hops    文件：CryptoOutputStream.java   

@Override
public void hflush() throws IOException {
  flush();
  if (out instanceof Syncable) {
    ((Syncable)out).hflush();
  }
}

项目：hops    文件：CryptoOutputStream.java   

@Override
public void hsync() throws IOException {
  flush();
  if (out instanceof Syncable) {
    ((Syncable)out).hsync();
  }
}