Package org.apache.hadoop.hbase.io.asyncfs

Class AsyncFSOutputHelper

java.lang.Object

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

@Private
public final class AsyncFSOutputHelper
extends Object

Helper class for creating AsyncFSOutput.

Constructor Summary

Constructors

Modifier	Constructor	Description
private	AsyncFSOutputHelper()

Method Summary

Modifier and Type	Method	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, boolean noLocalWrite)	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 Details

AsyncFSOutputHelper

private AsyncFSOutputHelper()

Method Details

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,
 boolean noLocalWrite)
                                  throws IOException,
CommonFSUtils.StreamLacksCapabilityException

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

Throws:

IOException

CommonFSUtils.StreamLacksCapabilityException