-
class
An asynchronous HDFS output stream implementation which fans out data to datanode and only
supports writing file with only one block.
class
AsyncFSOutputHelper.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
.
-
AsyncProtobufLogWriter.OutputStreamWrapper.out