org.apache.hadoop.fs.FSExceptionMessages#STREAM_IS_CLOSED源码实例Demo

下面列出了org.apache.hadoop.fs.FSExceptionMessages#STREAM_IS_CLOSED 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： hadoop-ozone 文件： KeyOutputStream.java

/**
 * Verify that the output stream is open. Non blocking; this gives
 * the last state of the volatile {@link #closed} field.
 * @throws IOException if the connection is closed.
 */
private void checkNotClosed() throws IOException {
  if (closed) {
    throw new IOException(
        ": " + FSExceptionMessages.STREAM_IS_CLOSED + " Key: "
            + blockOutputStreamEntryPool.getKeyName());
  }
}

源代码2 项目： hadoop-ozone 文件： KeyInputStream.java

/**
 * Verify that the input stream is open. Non blocking; this gives
 * the last state of the volatile {@link #closed} field.
 * @throws IOException if the connection is closed.
 */
private void checkOpen() throws IOException {
  if (closed) {
    throw new IOException(
        ": " + FSExceptionMessages.STREAM_IS_CLOSED + " Key: " + key);
  }
}

源代码3 项目： hadoop 文件： StrictBufferedFSInputStream.java

@Override
public void seek(long pos) throws IOException {
  if (pos < 0) {
    throw new EOFException(FSExceptionMessages.NEGATIVE_SEEK);
  }
  if (in == null) {
    throw new SwiftConnectionClosedException(FSExceptionMessages.STREAM_IS_CLOSED);
  }
  super.seek(pos);
}

源代码4 项目： big-c 文件： StrictBufferedFSInputStream.java

@Override
public void seek(long pos) throws IOException {
  if (pos < 0) {
    throw new EOFException(FSExceptionMessages.NEGATIVE_SEEK);
  }
  if (in == null) {
    throw new SwiftConnectionClosedException(FSExceptionMessages.STREAM_IS_CLOSED);
  }
  super.seek(pos);
}

源代码5 项目： hadoop 文件： S3AInputStream.java

private void checkNotClosed() throws IOException {
  if (closed) {
    throw new IOException(FSExceptionMessages.STREAM_IS_CLOSED);
  }
}

源代码6 项目： big-c 文件： S3AInputStream.java

private void checkNotClosed() throws IOException {
  if (closed) {
    throw new IOException(FSExceptionMessages.STREAM_IS_CLOSED);
  }
}

源代码7 项目： stocator 文件： COSInputStream.java

/**
 * Verify that the input stream is open. Non blocking; this gives
 * the last state of the volatile {@link #closed} field.
 * @throws IOException if the connection is closed
 */
private void checkNotClosed() throws IOException {
  if (closed) {
    throw new IOException(uri + ": " + FSExceptionMessages.STREAM_IS_CLOSED);
  }
}

方法所在类

org.apache.hadoop.fs.FSExceptionMessages