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.

Constructor Summary

Constructors

Modifier	Constructor and Description
private	AsyncFSOutputHelper()

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, StreamSlowMonitor monitor) 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

Constructor Detail

AsyncFSOutputHelper

private AsyncFSOutputHelper()

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,
                                         StreamSlowMonitor monitor)
                                  throws IOException,
                                         CommonFSUtils.StreamLacksCapabilityException

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

Throws:

IOException

CommonFSUtils.StreamLacksCapabilityException