-
FanOutOneBlockAsyncDFSOutputHelper.createOutput(org.apache.hadoop.hdfs.DistributedFileSystem dfs,
String src,
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)
FanOutOneBlockAsyncDFSOutputHelper.createOutput(org.apache.hadoop.hdfs.DistributedFileSystem dfs,
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)
void
private static void
(package private) static void
FanOutOneBlockAsyncDFSOutputHelper.completeFile(FanOutOneBlockAsyncDFSOutput output,
org.apache.hadoop.hdfs.DFSClient client,
org.apache.hadoop.hdfs.protocol.ClientProtocol namenode,
String src,
String clientName,
org.apache.hadoop.hdfs.protocol.ExtendedBlock block,
org.apache.hadoop.hdfs.protocol.HdfsFileStatus stat)
void
(package private) static void