Java 类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, 0, bytesWritten);
    ((Syncable) out).hflush();

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

    out.write(data, bytesWritten, 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, 0, bytesWritten);
    ((Syncable) out).hflush();

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

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

    in = getInputStream(defaultBufferSize);
    verify(in, dataLen, 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, 0, bytesWritten);
    ((Syncable) out).hflush();

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

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

    in = getInputStream(defaultBufferSize);
    verify(in, dataLen, 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, 0, bytesWritten);
    ((Syncable) out).hflush();

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

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

    in = getInputStream(defaultBufferSize);
    verify(in, dataLen, 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, 0, bytesWritten);
    ((Syncable) out).hflush();

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

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

    in = getInputStream(defaultBufferSize);
    verify(in, dataLen, 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, 0, bytesWritten);
    ((Syncable) out).hflush();

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

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

    in = getInputStream(defaultBufferSize);
    verify(in, dataLen, 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();
  }
}