org.apache.hadoop.hbase.io.asyncfs

Class AsyncFSOutputHelper

java.lang.Object

org.apache.hadoop.hbase.io.asyncfs.AsyncFSOutputHelper

@InterfaceAudience.Private
public final class AsyncFSOutputHelper
extends Object

Helper class for creating AsyncFSOutput.

Method Summary

Modifier and Type

Method and Description

static AsyncFSOutput

createOutput(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path f, boolean overwrite, boolean createParent, short replication, long blockSize, org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup, Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass) Create FanOutOneBlockAsyncDFSOutput for DistributedFileSystem, and a simple implementation for other FileSystem which wraps around a FSDataOutputStream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createOutput

public static AsyncFSOutput createOutput(org.apache.hadoop.fs.FileSystem fs,
                                         org.apache.hadoop.fs.Path f,
                                         boolean overwrite,
                                         boolean createParent,
                                         short replication,
                                         long blockSize,
                                         org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup eventLoopGroup,
                                         Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass)
                                  throws IOException,
                                         CommonFSUtils.StreamLacksCapabilityException

Create FanOutOneBlockAsyncDFSOutput for DistributedFileSystem, and a simple implementation for other FileSystem which wraps around a FSDataOutputStream.

Throws:

IOException

CommonFSUtils.StreamLacksCapabilityException